Struct workflow_rpc::server::Messenger

pub struct Messenger { /* private fields */ }

The Messenger struct is supplied to the RpcHandler::handshake() call at the connection negotiation time. This structure comes in as Arc<Messenger> and can be retained for later processing. It provides two methods: Messenger::notify that can be used asynchronously to dispatch RPC notifications to the client and Messenger::close that can be used to terminate the RPC connection with the client.

Implementations

impl Messenger

pub fn new(encoding: Encoding, sink: &WebSocketSink) -> Self

pub fn close(&self) -> Result<()>

pub async fn notify<Ops, Msg>(&self, op: Ops, msg: Msg) -> Result<()>where
    Ops: OpsT,
    Msg: BorshSerialize + BorshDeserialize + Serialize + Send + Sync + 'static,

Trait Implementations

impl Debug for Messenger

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.