Struct ComposeHandle 

pub struct ComposeHandle { /* private fields */ }

Producer side of a spawned node (ReconNode::spawn).

Implementations

impl ComposeHandle

pub fn node(&self) -> &ReconNode

The node.

pub fn send(&self, state: FrameState) -> Result<(), SendError>

Queues a state. Under Block waits for room; never waits otherwise.

pub fn try_send(&self, state: FrameState) -> Result<(), SendError>

Queues a state without waiting (Block returns SendError::Full when full).

pub fn send_all( &self, states: impl IntoIterator<Item = FrameState>, ) -> Result<(), SendError>

Queues every state of a source (iterator, channel receiver, …) with ComposeHandle::send.

pub fn stats(&self) -> QueueStats

Queue counters.

pub fn close( self, ) -> (Vec<Result<Outcome, ComposeError>>, Result<Closed, ComposeError>)

Sends End, waits for the worker to compose everything queued, and closes the node. Returns the per-state outcomes (in queue order) and the close result.

Trait Implementations

impl Debug for ComposeHandle

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

Formats the value using the given formatter.

impl Drop for ComposeHandle

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.