Struct AsyncCallbackManager

pub struct AsyncCallbackManager<Bkend, Cstrnt> { /* private fields */ }

Implementations

impl<Bkend, Cstrnt: PartialEq> AsyncCallbackManager<Bkend, Cstrnt>

pub fn new() -> Self

Get a new AsyncCallbackManager.

pub fn with_on_task_received_callback( self, cb: impl FnMut(TaskInformation<'_, Cstrnt>) + 'static, ) -> Self

pub fn with_on_response_received_callback( self, cb: impl FnMut(ResponseInformation) + 'static, ) -> Self

pub fn new_sender<Frntend>( &mut self, channel_size: usize, ) -> AsyncCallbackSender<Bkend, Frntend, Cstrnt>

Creates a new AsyncCallbackSender that sends to this Manager. Channel size refers to number of number of state mutations that can be buffered from tasks.

pub async fn manage_next_event( &mut self, backend: &Bkend, ) -> Option<ManagedEventType>

Manage the next event in the queue. Combination of spawn_next_task and process_next_response. Returns Some(ManagedEventType), if something was processed. Returns None, if no senders or tasks exist.

pub async fn spawn_next_task(&mut self, backend: &Bkend) -> Option<()>

Spawns the next incoming task from a sender. Returns Some(()), if a task was spawned. Returns None, if no senders.

pub async fn process_next_response(&mut self) -> Option<ResponseInformation>

Spawns the next incoming task from a sender. Returns Some(ResponseInformation), if a task was spawned. Returns None, if no senders. Note that the ‘on_next_response’ callback is not called, you’re given the ResponseInformation directly.

Trait Implementations

impl<Bkend, Cstrnt: PartialEq> Default for AsyncCallbackManager<Bkend, Cstrnt>

fn default() -> Self

Returns the “default value” for a type.