[][src]Struct mqttest::Mqttest

pub struct Mqttest {
    pub port: u16,
    pub fut: JoinHandle<Vec<ConnInfo>>,
}

Handle to a running server.

Fields

port: u16

Tcp port that the server is listening on.

fut: JoinHandle<Vec<ConnInfo>>

Methods

impl Mqttest[src]

pub async fn start(conf: Conf) -> Result<Mqttest, Error>[src]

Initialize a server with the given config, and start handling connections.

As soon as this function returns, the server is ready to accept connections. If the server is configured with a stop condition, you can wait for it using Mqttest.fut.

Auto Trait Implementations

impl !RefUnwindSafe for Mqttest

impl Send for Mqttest

impl Sync for Mqttest

impl Unpin for Mqttest

impl !UnwindSafe for Mqttest

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<V, T> VZip<V> for T where
    V: MultiLane<T>,