Streaming de Evenimente și Răspunsuri prin WebSockets în Învață Microsoft AutoGen: Sisteme Multi-Agent & Conversații Autonome

@app.websocket("/ws/agenti")
async def flux_evenimente(websocket: WebSocket):
    await websocket.accept()
    # Înregistrare callback pe fiecare replică nouă generată de agenți
    def trimite_update(sender, recipient, message):
        asyncio.create_task(websocket.send_json({
            "de_la": sender.name,
            "catre": recipient.name,
            "continut": message.get("content", "")
        }))