Trait StreamConsumer 

pub trait StreamConsumer: Send + 'static {
    type BarrierStream: Stream<Item = StreamResult<Barrier>> + Send;

    // Required method
    fn execute(self: Box<Self>) -> Self::BarrierStream;
}

StreamConsumer is the last step in an actor.

Required Associated Types

type BarrierStream: Stream<Item = StreamResult<Barrier>> + Send

Required Methods

fn execute(self: Box<Self>) -> Self::BarrierStream

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl StreamConsumer for DispatchExecutor

type BarrierStream = impl Stream<Item = Result<BarrierInner<Option<Arc<Mutation>>>, StreamError>> + Send

impl<S: StateStore> StreamConsumer for SyncLogStoreDispatchExecutor<S>

type BarrierStream = impl Stream<Item = Result<BarrierInner<Option<Arc<Mutation>>>, StreamError>> + Send