Trait rumq_broker::Network

pub trait Network: Stream<Item = Result<Packet, Error>> + Sink<Packet, Error = Error> + Unpin + Send { }

Implementors

impl<T> Network for T where
    T: Stream<Item = Result<Packet, Error>> + Sink<Packet, Error = Error> + Unpin + Send, 

Loading content...