Struct StreamWrapper 

pub struct StreamWrapper<B: EventStreamBackend> { /* private fields */ }

A wrapper around a backend stream that includes synchronization metadata.

This includes the stream itself, a map of last synchronized cursors from other streams, and the current cursor position for this stream. A backend stream plus the synchronization metadata the pool keeps beside it. Public only because it is the pool’s stream type in FailureStore::Factory; backends reach the stream itself, not this.

Trait Implementations

impl<B: EventStreamBackend> Debug for StreamWrapper<B>

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

Formats the value using the given formatter.

impl<B: EventStreamBackend> StreamMemory for StreamWrapper<B>

fn failure(&self, binding: &BufferBinding) -> Option<FailureId>

The failure claiming any byte the binding names, if one does.

fn taint( &mut self, binding: &BufferBinding, failure: FailureId, failures: &mut ErrorGraph, )

Point the bytes binding names at failure.

fn written(&mut self, binding: &BufferBinding, failures: &mut ErrorGraph)

The bytes binding names have a writer again: release every claim on them, and only on them.