[−][src]Struct jsonrpc_pubsub::oneshot::Sender
A sender part of the channel.
Implementations
impl<T> Sender<T>
[src]
pub fn send(self, t: T) -> Result<(), T>
[src]
Consume the sender and queue up an item to send.
This method returns right away and never blocks, there is no guarantee though that the message is received by the other end.
pub fn send_and_wait(self, t: T) -> impl Future<Output = Result<(), ()>>
[src]
Consume the sender and send an item.
The returned future will resolve when the message is received on the other end. Note that polling the future is actually not required to send the message as that happens synchronously. The future resolves to error in case the receiving end was dropped before being able to process the message.
Methods from Deref<Target = Sender<T>>
pub fn poll_canceled(&mut self, cx: &mut Context<'_>) -> Poll<()>
[src]
Polls this Sender
half to detect whether its associated
Receiver
has been dropped.
Return values
If Ready(())
is returned then the associated Receiver
has been
dropped, which means any work required for sending should be canceled.
If Pending
is returned then the associated Receiver
is still
alive and may be able to receive a message if sent. The current task,
however, is scheduled to receive a notification if the corresponding
Receiver
goes away.
pub fn cancellation(&mut self) -> Cancellation<'_, T>
[src]
Creates a future that resolves when this Sender
's corresponding
Receiver
half has hung up.
This is a utility wrapping poll_canceled
to expose a Future
.
pub fn is_canceled(&self) -> bool
[src]
Tests to see whether this Sender
's corresponding Receiver
has been dropped.
Unlike poll_canceled
, this function does not
enqueue a task for wakeup upon cancellation, but merely reports the
current state, which may be subject to concurrent modification.
pub fn is_connected_to(&self, receiver: &Receiver<T>) -> bool
[src]
Tests to see whether this Sender
is connected to the given Receiver
. That is, whether
they were created by the same call to channel
.
Trait Implementations
impl<T: Debug> Debug for Sender<T>
[src]
impl<T> Deref for Sender<T>
[src]
type Target = Sender<T>
The resulting type after dereferencing.
pub fn deref(&self) -> &Self::Target
[src]
impl<T> DerefMut for Sender<T>
[src]
Auto Trait Implementations
impl<T> !RefUnwindSafe for Sender<T>
[src]
impl<T> Send for Sender<T> where
T: Send,
[src]
T: Send,
impl<T> Sync for Sender<T> where
T: Send,
[src]
T: Send,
impl<T> Unpin for Sender<T>
[src]
impl<T> !UnwindSafe for Sender<T>
[src]
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, 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>,