Struct tokio_util::sync::mpsc::PollSenderFuture

struct PollSenderFuture<T>(ReusableBoxFuture<'static, Result<OwnedPermit<T>, PollSendError<T>>>);

Tuple Fields

0: ReusableBoxFuture<'static, Result<OwnedPermit<T>, PollSendError<T>>>

Implementations

impl<T> PollSenderFuture<T>

fn empty() -> Self

Create with an empty inner future with no Send bound.

impl<T: Send> PollSenderFuture<T>

fn new() -> Self

Create with an empty inner future.

fn poll( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<OwnedPermit<T>, PollSendError<T>>>

Poll the inner future.

fn set(&mut self, sender: Option<Sender<T>>)

Replace the inner future.

Trait Implementations

impl<T: Debug> Debug for PollSenderFuture<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.