Struct CoapTransport 

pub struct CoapTransport { /* private fields */ }

A CoAP client that implements the core [Transport] trait.

A transport is created disconnected; connect binds the socket and spawns the background task that decodes inbound datagrams for the life of the connection. Observe notifications are queued and read with recv.

Implementations

impl CoapTransport

pub fn new(config: CoapConfig) -> Self

Creates a transport from the given configuration without connecting.

Arguments

• config - the server connection settings.

Returns

A disconnected transport ready for connect.

pub fn is_connected(&self) -> bool

Reports whether the transport currently holds a bound socket.

Returns

true once connect has succeeded and before disconnect is called.

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

Awaits the next notification from an observed resource.

Returns

Some(message) for the next queued notification, or None once the background task has stopped and no further messages will arrive.

Errors

Returns [Error::Closed] if the transport is not connected.

pub async fn disconnect(&mut self) -> Result<()>

Closes the socket and stops the background task.

Calling this on a transport that is not connected is a no-op.

Returns

Ok(()) once the background task has been stopped and the socket released.

Errors

This call is best-effort and currently always returns Ok(()).

Trait Implementations

impl Transport for CoapTransport

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.