Struct AsyncCallback 

pub struct AsyncCallback<F> { /* private fields */ }

A cloneable, thread-safe handle that injects a callback into the stage’s execution context. The callback is serialized with element processing: callbacks are buffered in a lock-protected queue and drained by the fused executor between element deliveries — the callback itself runs on the executor thread, not the invoker’s thread.

Implementations

impl<F> AsyncCallback<F>

where F: Fn(&mut GraphStageLogic) + Send + Sync + 'static,

pub fn invoke(&self, logic: &mut GraphStageLogic)

pub fn invoke_without_logic(&self)

Trait Implementations

impl<F> Clone for AsyncCallback<F>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.