Struct Buffer 

pub struct Buffer<Op: Operation> { /* private fields */ }

A route that simply collects requests for the caller to drain and handle.

Unlike Serialized and Parked, this lane does no FFI or id bookkeeping: the routing closure pushes each request with Buffer::push, and the surrounding code later calls Buffer::drain to take and handle them. This is convenient for tests and for simple, synchronous in-process handlers.

Implementations

impl<Op: Operation> Buffer<Op>

pub fn push(&self, request: Request<Op>)

Store a request for the caller to drain and handle.

Panics

Panics if the internal mutex has been poisoned.

pub fn drain(&self) -> Vec<Request<Op>>

Take all currently buffered requests.

Panics

Panics if the internal mutex has been poisoned.

Trait Implementations

impl<Op: Operation> Default for Buffer<Op>

fn default() -> Self

Returns the “default value” for a type.