Struct CallbackTransport 

pub struct CallbackTransport { /* private fields */ }

A transport whose every operation is a host callback.

Built by pamoja_transport_from_callbacks and held inside a PamojaTransport, so it composes wherever a transport does.

Trait Implementations

impl Drop for CallbackTransport

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl Receive for CallbackTransport

async fn recv(&mut self) -> Result<Option<Message>>

Awaits the next message the host delivered.

Returns

Some(message) for the next queued message; None once the host reported the link ended or after a failure was reported, or at once for a host with no recv.

Errors

Returns [Error::Closed] if the transport is not connected, and once the failure the host’s recv reported, after which it is called no more until the next connect.

impl Transport for CallbackTransport

async fn connect(&mut self) -> Result<()>

Establishes the connection to the broker, peer, or bus.

async fn send(&mut self, topic: &str, payload: &[u8]) -> Result<()>

Publishes a payload to a topic.

async fn subscribe(&mut self, topic: &str) -> Result<()>

Subscribes to a topic so that matching payloads are routed to this transport.

fn send_text( &mut self, topic: &str, text: &str, ) -> impl Future<Output = Result<(), Error>> + Send

Publishes text to a topic: words, or a number written out.