Struct BlockingSink 

pub struct BlockingSink<T: SyncProjectionSink> { /* private fields */ }

Adapter turning a SyncProjectionSink into a ProjectionSink.

Implementations

impl<T: SyncProjectionSink> BlockingSink<T>

pub fn new(inner: T) -> Self

Wrap inner in spawn_blocking dispatch — the safe default for any sink that may block.

pub fn inline(inner: T) -> Self

Wrap inner in inline dispatch. Use only for fast in-memory sinks; see Dispatch::Inline.

pub fn inner(&self) -> &Arc<T>

Access the wrapped sink. Useful for tests that need to peek at accumulated state after the async dispatch loop advanced the checkpoint.

Trait Implementations

impl<T: SyncProjectionSink> ProjectionSink for BlockingSink<T>

fn id(&self) -> &str

Stable identifier used as the checkpoint key.

fn commit<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, stream: &'life1 StreamId, seq: Seq, state: &'life2 Value, event: &'life3 Event, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Apply a single committed event.

fn on_label_set<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, stream: &'life1 StreamId, label: &'life2 Label, at: Seq, state: &'life3 Value, event: &'life4 Event, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

React to a label being pinned or moved.

fn on_label_deleted<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, stream: &'life1 StreamId, label: &'life2 Label, ) -> Pin<Box<dyn Future<Output = Result<(), StoreError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

React to a label being deleted.

fn accepts(&self, _stream: &StreamId) -> bool

Whether this sink is interested in stream.