[−][src]Struct rumqttc::Client
Client
to communicate with MQTT eventloop Connection
.
Client is cloneable and can be used to synchronously Publish, Subscribe. Asynchronous channel handle can also be extracted if necessary
Implementations
impl Client
[src]
pub fn new(options: MqttOptions, cap: usize) -> (Client, Connection)
[src]
Create a new Client
pub fn publish<S, V>(
&mut self,
topic: S,
qos: QoS,
retain: bool,
payload: V
) -> Result<(), ClientError> where
S: Into<String>,
V: Into<Vec<u8>>,
[src]
&mut self,
topic: S,
qos: QoS,
retain: bool,
payload: V
) -> Result<(), ClientError> where
S: Into<String>,
V: Into<Vec<u8>>,
Sends a MQTT Publish to the eventloop
pub fn subscribe<S: Into<String>>(
&mut self,
topic: S,
qos: QoS
) -> Result<(), ClientError>
[src]
&mut self,
topic: S,
qos: QoS
) -> Result<(), ClientError>
Sends a MQTT Subscribe to the eventloop
pub fn subscribe_many<T>(&mut self, topics: T) -> Result<(), ClientError> where
T: IntoIterator<Item = SubscribeTopic>,
[src]
T: IntoIterator<Item = SubscribeTopic>,
Sends a MQTT Subscribe for multiple topics to the eventloop
pub fn unsubscribe<S: Into<String>>(
&mut self,
topic: S
) -> Result<(), ClientError>
[src]
&mut self,
topic: S
) -> Result<(), ClientError>
Sends a MQTT Unsubscribe to the eventloop
pub fn disconnect(&mut self) -> Result<(), ClientError>
[src]
Sends a MQTT disconnect to the eventloop
pub fn cancel(&mut self) -> Result<(), ClientError>
[src]
Stops the eventloop right away
Trait Implementations
Auto Trait Implementations
impl RefUnwindSafe for Client
impl Send for Client
impl Sync for Client
impl Unpin for Client
impl UnwindSafe for Client
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,