Type Alias ThreadPusher

pub type ThreadPusher<T> = Pusher<T, Pusher<T>>;

Thread-local counting channel push endpoint.

Aliased Type

struct ThreadPusher<T> { /* private fields */ }

Implementations

impl<T, P: Push<T>> Pusher<T, P>

pub fn new(pusher: P, index: usize, events: Rc<RefCell<Vec<usize>>>) -> Self

Wraps a pusher with a message counter.

Trait Implementations

impl<T, P: Push<T>> Push<T> for Pusher<T, P>

fn push(&mut self, element: &mut Option<T>)

Pushes element with the opportunity to take ownership.

fn send(&mut self, element: T)

Pushes element and drops any resulting resources.

fn done(&mut self)

Pushes None, conventionally signalling a flush.