Struct ReadProtocol 

pub struct ReadProtocol { /* private fields */ }

Implementations

impl ReadProtocol

pub fn new(provider: impl Reader) -> Self

pub async fn read<E: Event>( &self, id: impl ToEntityId, seq: i64, ) -> Result<E, ProtocolError>

pub async fn read_to( &self, id: impl ToEntityId, from: i64, to: i64, ) -> Result<BTreeSet<Payload>, ProtocolError>

pub async fn read_to_latest( &self, id: impl ToEntityId, from: i64, ) -> Result<BTreeSet<Payload>, ProtocolError>

Trait Implementations

impl Clone for ReadProtocol

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReadProtocol

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

Formats the value using the given formatter.