fn to_flight_data_stream( output: Output, tracing_context: TracingContext, ) -> TonicStream<FlightData>