Function to_flight_data_stream 

fn to_flight_data_stream<F>(
    output: F,
    tracing_context: TracingContext,
    flight_compression: FlightCompression,
    query_ctx: QueryContextRef,
    should_emit_terminal_metrics: bool,
) -> TonicStream<FlightData>
where
    F: Future<Output = Result<Output>> + Send + 'static,