Function _ndjson_updates

nextpy/app.py:1023–1034

Process the upload event, generating ndjson updates. Yields: Each state update as JSON followed by a new line.

()

        )

        async def _ndjson_updates():
            """Process the upload event, generating ndjson updates.

            Yields:
                Each state update as JSON followed by a new line.
            """
            # Process the event.
            async with app.state_manager.modify_state(token) as state:
                async for update in state._process(event):
                    # Postprocess the event.
                    update = await app.postprocess(state, event, update)
                    yield update.json() + "\n"

        # Stream updates to client
        return StreamingResponse(