Struct Subscriber

pub struct Subscriber<const MCL: usize, const MCC: usize, const MPL: usize, N, S, PD, AT, Err> { /* private fields */ }

The public-facing part of a subscriber (to be returned by Store::subscribe_area).

Trait Implementations

impl<const MCL: usize, const MCC: usize, const MPL: usize, N: Debug, S: Debug, PD: Debug, AT: Debug, Err: Debug> Debug for Subscriber<MCL, MCC, MPL, N, S, PD, AT, Err>

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

Formats the value using the given formatter.

impl<const MCL: usize, const MCC: usize, const MPL: usize, N, S, PD, AT, Err> Drop for Subscriber<MCL, MCC, MPL, N, S, PD, AT, Err>

fn drop(&mut self)

Executes the destructor for this type.

impl<const MCL: usize, const MCC: usize, const MPL: usize, N, S, PD, AT, Err> Producer for Subscriber<MCL, MCC, MPL, N, S, PD, AT, Err>

where N: Clone, S: PartialEq + Clone, PD: Clone, AT: Clone,

type Item = StoreEvent<MCL, MCC, MPL, N, S, PD, AT>

The sequence produced by this producer starts with arbitrarily many values of this type.

type Final = ()

The sequence produced by this producer ends with up to one value of this type.

type Error = Err

The type of errors the producer can emit instead of doing its job.

async fn produce( &mut self, ) -> Result<Either<Self::Item, Self::Final>, Self::Error>

Attempts to produce the next item, which is either a regular repeated item or the final item.

fn produce_item( &mut self, ) -> impl Future<Output = Result<Self::Item, ProduceAtLeastError<Self::Final, Self::Error>>>

Tries to produce a regular item, and reports an error if the final item was produced instead.

fn overwrite_full_slice( &mut self, buf: &mut [Self::Item], ) -> impl Future<Output = Result<(), ProduceAtLeastError<Self::Final, Self::Error>>>

Tries to completely overwrite a slice with items from a producer. Reports an error if the slice could not be overwritten completely.