Function output_from_flight_message_stream 

async fn output_from_flight_message_stream<S>(
    remote_addr: String,
    flight_message_stream: S,
) -> Result<OutputWithMetrics>
where
    S: Stream<Item = Result<FlightMessage>> + Send + Unpin + 'static,