Struct rerun::sink::CallbackSink

pub struct CallbackSink {
    callback: Box<dyn Fn(&[LogMsg]) + Sync + Send>,
}

A sink which forwards all log messages to a callback without any buffering.

Fields

callback: Box<dyn Fn(&[LogMsg]) + Sync + Send>

Implementations

impl CallbackSink

pub fn new<F>(callback: F) -> CallbackSink

where F: Fn(&[LogMsg]) + Send + Sync + 'static,

Create a new CallbackSink with the given callback function.

Trait Implementations

impl LogSink for CallbackSink

fn send(&self, msg: LogMsg)

Send this log message.

fn send_all(&self, messages: Vec<LogMsg>)

Send all these log messages.

fn flush_blocking(&self)

Blocks until all pending data in the sink’s send buffers has been fully flushed.

fn drain_backlog(&self) -> Vec<LogMsg>

Drain all buffered LogMsges and return them.

fn drop_if_disconnected(&self)

Drops all pending data currently sitting in the sink’s send buffers if it is unable to flush it for any reason (e.g. a broken TCP connection for a TcpSink).

fn send_blueprint( &self, blueprint: Vec<LogMsg>, activation_cmd: BlueprintActivationCommand )

Send a blueprint directly to the log-sink.