Struct Outbox 

pub struct Outbox(/* private fields */);

Handle for publishing into a Service.

This is intended to be held by implementers of ZeekClient to publish events to Zeek, and is created during e.g., Service::new. Service holds on to the receiving side and will keep checking it. Dropping the Outbox indicates to the Service that the client is done and will cause it to terminate, so clients should hold the Outbox for as long as they intend to stay connected, and explicitly drop it.

Implementations

impl Outbox

pub async fn send( &self, topic: String, event: Event, ) -> Result<(), (String, Event)>

Enqueue an event on the given topic.

Errors

Returns back the enqueued event when the outbox has been closed.

Trait Implementations

impl Clone for Outbox

fn clone(&self) -> Outbox

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.