in 3-ai-native-e2e-sample/backend/agents/literature.py [0:0]
def on_message_delta(self, delta: MessageDeltaChunk) -> Generator[Union[str, Dict[str, Any]], None, None]:
"""Handle streaming message chunks."""
if delta.text:
logger.debug(f"Received message delta: {delta.text[:100]}...")
return json.dumps({
"type": "delta",
"content": delta.text
})
return None