diff --git a/rumqttc/src/client.rs b/rumqttc/src/client.rs index a0c907049..cb58cf82d 100644 --- a/rumqttc/src/client.rs +++ b/rumqttc/src/client.rs @@ -450,10 +450,10 @@ impl Connection { Iter { connection: self } } - /// Attempt to fetch an incoming [`Event`] on the [`EvenLoop`], returning an error + /// Attempt to fetch an incoming [`Event`] on the [`EventLoop`], returning an error /// if all clients/users have closed requests channel. /// - /// [`EvenLoop`]: super::EventLoop + /// [`EventLoop`]: super::EventLoop pub fn recv(&mut self) -> Result, RecvError> { let f = self.eventloop.poll(); let event = self.runtime.block_on(f); @@ -461,10 +461,10 @@ impl Connection { resolve_event(event).ok_or(RecvError) } - /// Attempt to fetch an incoming [`Event`] on the [`EvenLoop`], returning an error + /// Attempt to fetch an incoming [`Event`] on the [`EventLoop`], returning an error /// if none immediately present or all clients/users have closed requests channel. /// - /// [`EvenLoop`]: super::EventLoop + /// [`EventLoop`]: super::EventLoop pub fn try_recv(&mut self) -> Result, TryRecvError> { let f = self.eventloop.poll(); // Enters the runtime context so we can poll the future, as required by `now_or_never()`. @@ -475,10 +475,10 @@ impl Connection { resolve_event(event).ok_or(TryRecvError::Disconnected) } - /// Attempt to fetch an incoming [`Event`] on the [`EvenLoop`], returning an error + /// Attempt to fetch an incoming [`Event`] on the [`EventLoop`], returning an error /// if all clients/users have closed requests channel or the timeout has expired. /// - /// [`EvenLoop`]: super::EventLoop + /// [`EventLoop`]: super::EventLoop pub fn recv_timeout( &mut self, duration: Duration, diff --git a/rumqttc/src/v5/client.rs b/rumqttc/src/v5/client.rs index 4913d1d0f..7a86333f2 100644 --- a/rumqttc/src/v5/client.rs +++ b/rumqttc/src/v5/client.rs @@ -798,10 +798,10 @@ impl Connection { Iter { connection: self } } - /// Attempt to fetch an incoming [`Event`] on the [`EvenLoop`], returning an error + /// Attempt to fetch an incoming [`Event`] on the [`EventLoop`], returning an error /// if all clients/users have closed requests channel. /// - /// [`EvenLoop`]: super::EventLoop + /// [`EventLoop`]: super::EventLoop pub fn recv(&mut self) -> Result, RecvError> { let f = self.eventloop.poll(); let event = self.runtime.block_on(f); @@ -809,10 +809,10 @@ impl Connection { resolve_event(event).ok_or(RecvError) } - /// Attempt to fetch an incoming [`Event`] on the [`EvenLoop`], returning an error + /// Attempt to fetch an incoming [`Event`] on the [`EventLoop`], returning an error /// if none immediately present or all clients/users have closed requests channel. /// - /// [`EvenLoop`]: super::EventLoop + /// [`EventLoop`]: super::EventLoop pub fn try_recv(&mut self) -> Result, TryRecvError> { let f = self.eventloop.poll(); // Enters the runtime context so we can poll the future, as required by `now_or_never()`. @@ -823,10 +823,10 @@ impl Connection { resolve_event(event).ok_or(TryRecvError::Disconnected) } - /// Attempt to fetch an incoming [`Event`] on the [`EvenLoop`], returning an error + /// Attempt to fetch an incoming [`Event`] on the [`EventLoop`], returning an error /// if all clients/users have closed requests channel or the timeout has expired. /// - /// [`EvenLoop`]: super::EventLoop + /// [`EventLoop`]: super::EventLoop pub fn recv_timeout( &mut self, duration: Duration,