Function enqueue_stream_delta

tests/units/test_app.py:1359–1364

(_token, _event)

    stream_closed = asyncio.Event()

    async def enqueue_stream_delta(_token, _event):
        try:
            yield {"state": {"ok": True}}
            await asyncio.Event().wait()
        finally:
            stream_closed.set()

    app = Mock(
        event_processor=Mock(enqueue_stream_delta=enqueue_stream_delta),