,1287,717.01,4,Queens,071701,4071701,I,QN18,Rego Park,4108,673,499,4,Queens,049900,4049900,E,QN29,Elmhurst,4107^3389294,2,2014-03-21 19:36:13,2014-03-21 19:46:30,N,1,-73.862640380859375,40.730381011962891,-73.858734130859375,40.716056823730469,1,2.01,9.5,1,0.5,0,0,,,11,1,1,196,196,green,0.00,0.0,0.0,51,39,7.61,1287,717.01,4,Queens,071701,4071701,I,QN18,Rego Park,4108,1877,703,4,Queens,070300,4070300,I,QN18,Rego Park,4108^3389295,2,2014-03-22 17:50:25,2014-03-22 18:01:43,N,1,-73.862495422363281,4...

                    # streaming response completes — not by async generator
                    # finalization via GeneratorExit.
                    # Ref: https://peps.python.org/pep-0789/
                    send_stream, receive_stream = anyio.create_memory_object_stream[
                        bytes
                    ](max_buffer_size=1)

                    async def _producer() -> None: