Struct Context 

pub struct Context {
    pub emitter: StreamEmitter,
    pub data: Arc<RwLock<TypeMap>>,
    /* private fields */
}

An object provided to each callback function. Currently it only holds the event emitter to emit response events in event callbacks.

use rmp_ipc::prelude::*;

async fn my_callback(ctx: &Context, _event: Event) -> IPCResult<()> {
    // use the emitter on the context object to emit events
    // inside callbacks
    ctx.emitter.emit("ping", ()).await?;
    Ok(())
}

Fields

emitter: StreamEmitter

The event emitter

data: Arc<RwLock<TypeMap>>

Field to store additional context data

Implementations

impl Context

pub async fn await_reply(&self, message_id: u64) -> Result<Event>

Waits for a reply to the given message ID

pub async fn stop(self) -> Result<()>

Stops the listener and closes the connection

Trait Implementations

impl Clone for Context

fn clone(&self) -> Context

Returns a duplicate of the value.

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

Performs copy-assignment from source.