# Streaming
import os
from anthropic import Anthropic
from dotenv import load_dotenv
load_dotenv()
 
client = Anthropic(api_key=os.getenv("ANTHROPIC_API_KEY"))
 
with client.messages.stream(
    model="claude-haiku-4-5-20251001",
    max_tokens=500,
    messages=[{"role": "user", "content": "Türk kahvesi tarihini 5 paragrafta anlat."}]
) as stream:
    for text in stream.text_stream:
        print(text, end="", flush=True)
 
print("\n\n--- Bitti ---")
 

# Streaming JSON — naïve buffer
buffer = ""
items_seen = []
 
with client.messages.stream(...) as stream:
    for text in stream.text_stream:
        buffer += text
        # Her } gördüğümüzde dene parse
        if "}" in text:
            try:
                # Partial JSON parse (json5 lib)
                import json5
                parsed = json5.loads(buffer + "}")  # naïve
                if "items" in parsed and len(parsed["items"]) > len(items_seen):
                    new_item = parsed["items"][-1]
                    print(f"Yeni item: {new_item}")
                    items_seen.append(new_item)
            except:
                pass