Struct AsyncClientBuilder 

pub struct AsyncClientBuilder { /* private fields */ }

Builder for asynchronous MQTT clients.

The request channel is bounded by default using MqttOptions::request_channel_capacity. Use Self::capacity to override the bounded capacity, or Self::unbounded to opt into an unbounded request channel.

Implementations

impl AsyncClientBuilder

pub const fn new(options: MqttOptions) -> Self

Create a new builder for an asynchronous AsyncClient.

pub const fn capacity(self, cap: usize) -> Self

Use a bounded request channel with the given capacity.

0 creates a bounded zero-capacity rendezvous channel. Use Self::unbounded for an unbounded request channel.

pub const fn unbounded(self) -> Self

Use an unbounded request channel.

pub fn build(self) -> (AsyncClient, EventLoop)

Build an asynchronous client and event loop.

This builder always produces the asynchronous client pair so the terminal build() method matches the entry point that created it.

Trait Implementations

impl Debug for AsyncClientBuilder

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

Formats the value using the given formatter.