Struct tokio_util::sync::PollSender[][src]

pub struct PollSender<T> { /* fields omitted */ }
Expand description

A wrapper around mpsc::Sender that can be polled.

Implementations

Create a new PollSender.

Start sending a new item.

This method panics if a send is currently in progress. To ensure that no send is in progress, call poll_send_done first until it returns Poll::Ready.

If this method returns an error, that indicates that the channel is closed. Note that this method is not guaranteed to return an error if the channel is closed, but in that case the error would be reported by the first call to poll_send_done.

If a send is in progress, poll for its completion. If no send is in progress, this method returns Poll::Ready(Ok(())).

This method can return the following values:

  • Poll::Ready(Ok(())) if the in-progress send has been completed, or there is no send in progress (even if the channel is closed).
  • Poll::Ready(Err(err)) if the in-progress send failed because the channel has been closed.
  • Poll::Pending if a send is in progress, but it could not complete now.

When this method returns Poll::Pending, the current task is scheduled to receive a wakeup when the message is sent, or when the entire channel is closed (but not if just this sender is closed by close_this_sender). Note that on multiple calls to poll_send_done, only the Waker from the Context passed to the most recent call is scheduled to receive a wakeup.

If this method returns Poll::Ready, then start_send is guaranteed to not panic.

Check whether the channel is ready to send more messages now.

If this method returns true, then start_send is guaranteed to not panic.

If the channel is closed, this method returns true.

Check whether the channel has been closed.

Clone the underlying Sender.

If this method returns None, then the channel is closed. (But it is not guaranteed to return None if the channel is closed.)

Access the underlying Sender.

If this method returns None, then the channel is closed. (But it is not guaranteed to return None if the channel is closed.)

Close this sender. No more messages can be sent from this sender.

Note that this only closes the channel from the view-point of this sender. The channel remains open until all senders have gone away, or until the Receiver closes the channel.

If there is a send in progress when this method is called, that send is unaffected by this operation, and poll_send_done can still be called to complete that send.

Abort the current in-progress send, if any.

Returns true if a send was aborted.

Trait Implementations

Clones this PollSender. The resulting clone will not have any in-progress send operations, even if the current PollSender does.

Performs copy-assignment from source. Read more

Formats the value using the given formatter. Read more

This is equivalent to calling poll_send_done.

This is equivalent to calling poll_send_done.

This is equivalent to calling start_send.

This method will first flush the PollSender, and then close it by calling close_this_sender.

If a send fails while flushing because the Receiver has gone away, then this function returns an error. The channel is still successfully closed in this situation.

The type of value produced by the sink when an error occurs.

Auto Trait Implementations

Blanket Implementations

Gets the TypeId of self. Read more

Immutably borrows from an owned value. Read more

Mutably borrows from an owned value. Read more

Performs the conversion.

Performs the conversion.

The resulting type after obtaining ownership.

Creates owned data from borrowed data, usually by cloning. Read more

🔬 This is a nightly-only experimental API. (toowned_clone_into)

Uses borrowed data to replace owned data, usually by cloning. Read more

The type returned in the event of a conversion error.

Performs the conversion.

The type returned in the event of a conversion error.

Performs the conversion.