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

Implementors

impl StreamConsumer for DispatchExecutor

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