Struct tikv_util::mpsc::batch::State[−][src]

struct State {
    recv_task: AtomicPtr<Waker>,
    notify_size: usize,
    pending: AtomicUsize,
    notifier_registered: AtomicBool,
}

Fields

recv_task: AtomicPtr<Waker>notify_size: usizepending: AtomicUsizenotifier_registered: AtomicBool

Implementations

impl State[src][−]

fn new(notify_size: usize) -> State[src]

fn try_notify_post_send(&self)[src]

fn notify(&self)[src]

fn yield_poll(&self, waker: Waker) -> bool[src][−]

When the Receiver that holds the State is running on an Executor, the Receiver calls this to yield from the current poll context, and puts the current task handle to recv_task, so that the Sender respectively can notify it after sending some messages into the channel.

Trait Implementations

impl Drop for State[src][+]

Auto Trait Implementations

impl RefUnwindSafe for State

impl Send for State

impl Sync for State

impl Unpin for State

impl UnwindSafe for State

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized, [src][+]

impl<T> Borrow<T> for T where
    T: ?Sized, [src][+]

impl<T> BorrowMut<T> for T where
    T: ?Sized, [src][+]

impl<T> From<T> for T[src][+]

impl<T> Instrument for T[src][+]

impl<T, U> Into<U> for T where
    U: From<T>, [src][+]

impl<T> Pointable for T[src][+]

type Init = T

The type for initializers.

impl<T> Same<T> for T[src]

type Output = T

Should always be Self

impl<T> Sealed<T> for T where
    T: ?Sized, [src]

impl<T> SendSyncUnwindSafe for T where
    T: Send + Sync + UnwindSafe + ?Sized, [src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, [src][+]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, [src][+]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<V, T> VZip<V> for T where
    V: MultiLane<T>, [src][+]