Struct futures_channel::mpsc::UnboundedSenderInner

struct UnboundedSenderInner<T> {
    inner: Arc<UnboundedInner<T>>,
}

Fields

inner: Arc<UnboundedInner<T>>

Implementations

impl<T> UnboundedSenderInner<T>

fn poll_ready_nb(&self) -> Poll<Result<(), SendError>>

fn queue_push_and_signal(&self, msg: T)

fn inc_num_messages(&self) -> Option<usize>

fn same_receiver(&self, other: &Self) -> bool

Returns whether the senders send to the same receiver.

fn is_connected_to(&self, inner: &Arc<UnboundedInner<T>>) -> bool

Returns whether the sender send to this receiver.

fn ptr(&self) -> *const UnboundedInner<T>

Returns pointer to the Arc containing sender

The returned pointer is not referenced and should be only used for hashing!

fn is_closed(&self) -> bool

Returns whether this channel is closed without needing a context.

fn close_channel(&self)

Closes this channel from the sender side, preventing any new messages.

Trait Implementations

impl<T> Clone for UnboundedSenderInner<T>

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T> Drop for UnboundedSenderInner<T>

fn drop(&mut self)

Executes the destructor for this type.

impl<T> Unpin for UnboundedSenderInner<T>