Struct ockam::Context

pub struct Context { /* fields omitted */ }

Implementations

impl Context

pub fn address(&self) -> Address

Return the current context address

During initialisation and shutdown this will return the primary worker address. During message handling it will return the address the message was addressed to.

pub async fn start_worker<NM, NW, S>(
    &'_ self,
    address: S,
    worker: NW
) -> Result<(), Error> where
    S: Into<AddressSet>,
    NM: Message + Send + 'static,
    NW: Worker<Context = Context, Message = NM>, 

Start a new worker handle at Address

pub async fn stop(&'_ self) -> Result<(), Error>

Signal to the local application runner to shut down

pub async fn send_message<S, M>(
    &'_ self,
    address: S,
    msg: M
) -> Result<(), Error> where
    S: Into<Address>,
    M: Message + Send + 'static, 

Send a message to a particular worker

pub async fn receive<M>(&'ctx mut self) -> Result<Cancel<'ctx, M>, Error> where
    M: Message, 

Block the current worker to wait for a typed message

Will return None if the corresponding worker has been stopped, or the underlying Node has shut down.

pub async fn list_workers(&'_ self) -> Result<Vec<Address, Global>, Error>

Return a list of all available worker addresses on a node