in core/realtime.py [0:0]
def __init__( self, output_queue: asyncio.Queue[ProcessorPart | None], generation: Processor, rolling_prompt: _RollingPrompt, user_not_talking: asyncio.Event,