Struct jsonrpsee_ws_client::WsSubscription [−][src]
Active subscription on a Client.
Fields
to_back: Sender<FrontToBack>
Channel to send requests to the background task.
notifs_rx: Receiver<Value>
Channel from which we receive notifications from the server, as encoded JsonValue
s.
id: SubscriptionId
Subscription ID,
marker: PhantomData<Notif>
Marker in order to pin the Notif
parameter.
Implementations
impl<Notif> Subscription<Notif> where
Notif: DeserializeOwned,
[src]
Notif: DeserializeOwned,
pub async fn next(&'_ mut self) -> Option<Notif>
[src]
Returns the next notification from the stream
This may return None
if the subscription has been terminated,
may happen if the channel becomes full or is dropped.
Ignores any malformed packet.
Trait Implementations
impl<Notif> Drop for Subscription<Notif>
[src]
Auto Trait Implementations
impl<Notif> !RefUnwindSafe for Subscription<Notif>
impl<Notif> Send for Subscription<Notif> where
Notif: Send,
Notif: Send,
impl<Notif> Sync for Subscription<Notif> where
Notif: Sync,
Notif: Sync,
impl<Notif> Unpin for Subscription<Notif> where
Notif: Unpin,
Notif: Unpin,
impl<Notif> !UnwindSafe for Subscription<Notif>
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> Same<T> for T
type Output = T
Should always be Self
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>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,