Ki olvasná ki a sorból származó eredményeket, mentené az üzeneteket és a beszélgetéseket adatbázisokba, és küldene streaming adatokat egy nyitott SSE kapcsolatba?