/// Drain a `LoggerStream` which wraps a socket from a component generating logs.
Drain a `LoggerStream` which wraps a socket from a component generating logs.
Drain a ` LoggerStream ` which wraps a socket from a component generating logs .
async fn drain_messages(self, mut log_stream: LogMessageSocket) {
        while let Some(next) = log_stream.next().await {
            match next {
                Ok(log_msg) => {
                    self.ingest_message(log_msg, stats::LogSource::LogSink).await;
                }
                Err(e) => {
                    eprintln!("log stream errored: {:?}", e);
                    return;
                }
            }
        }
    }
async fn drain_messages ( self , mut log_stream : LogMessageSocket ) { while let Some ( next ) = log_stream . next ( ) . await { match next { Ok ( log_msg ) => { self . ingest_message ( log_msg , stats :: LogSource :: LogSink ) . await ; } Err ( e ) => { eprintln ! ( " " e ) ; return ; } } } }
Drain a `LoggerStream` which wraps a socket from a component generating logs.
Drain a ` LoggerStream ` which wraps a socket from a component generating logs .
self
log_stream
LogMessageSocket