Struct AsyncCallbackSender

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

Implementations

impl<Bkend, Frntend, Cstrnt> AsyncCallbackSender<Bkend, Frntend, Cstrnt>

pub async fn get_next_mutations( &mut self, max_mutations: usize, ) -> StateMutationBundle<Frntend>

pub fn add_stream_callback<R>( &self, request: R, handler: impl FnOnce(&mut Frntend, R::Output) + Send + Clone + 'static, constraint: Option<Constraint<Cstrnt>>, ) -> Result<()>

where R: BackendStreamingTask<Bkend, MetadataType = Cstrnt> + 'static, Bkend: Send + 'static, Frntend: 'static,

Errors

This will return an error if the manager has been dropped.

pub fn add_callback<R>( &self, request: R, handler: impl FnOnce(&mut Frntend, R::Output) + Send + 'static, constraint: Option<Constraint<Cstrnt>>, ) -> Result<()>

where R: BackendTask<Bkend, MetadataType = Cstrnt> + 'static, Bkend: Send + 'static, Frntend: 'static,

Errors

This will return an error if the manager has been dropped.