Struct Session

pub struct Session<SP: StorageProvider, E> { /* private fields */ }

Ephemeral session used to handle/generate off-graph commands.

Implementations

impl<SP: StorageProvider, E: Engine> Session<SP, E>

pub fn action<ES, MS>( &mut self, client: &ClientState<E, SP>, effect_sink: &mut ES, message_sink: &mut MS, action: <E::Policy as Policy>::Action<'_>, ) -> Result<(), ClientError>

where ES: Sink<E::Effect>, MS: for<'b> Sink<&'b [u8]>,

Evaluate an action on the ephemeral session and generate serialized commands, so another client can Session::receive them.

pub fn receive( &mut self, client: &ClientState<E, SP>, sink: &mut impl Sink<E::Effect>, command_bytes: &[u8], ) -> Result<(), ClientError>

Handle a command from another client generated by Session::action.

You do NOT need to reprocess the commands from actions generated in the same session.