/// Spawn a task to handle requests from components with logs.
Spawn a task to handle requests from components with logs.
Spawn a task to handle requests from components with logs .
pub fn spawn_log_sink_handler(&self, stream: LogSinkRequestStream, source: SourceIdentity) {
        let handler = self.clone();
        fasync::spawn(async move {
            if let Err(e) = handler.handle_log_sink_requests(stream, source).await {
                eprintln!("logsink stream errored: {:?}", e);
            }
        })
    }
pub fn spawn_log_sink_handler ( & self , stream : LogSinkRequestStream , source : SourceIdentity ) { let handler = self . clone ( ) ; fasync :: spawn ( async move { if let Err ( e ) = handler . handle_log_sink_requests ( stream , source ) . await { eprintln ! ( " " e ) ; } } ) }
Spawn a task to handle requests from components with logs.
Spawn a task to handle requests from components with logs .
&self
stream
LogSinkRequestStream
source
SourceIdentity