Trait Backend

pub trait Backend<Req> {
    type Stream: Stream<Item = Result<Option<Req>, Error>>;
    type Layer;
    type Codec: Codec;

    // Required method
    fn poll(self, worker: &Worker<Context>) -> Poller<Self::Stream, Self::Layer>;
}

A backend represents a task source Both Storage and MessageQueue need to implement it for workers to be able to consume tasks

Required Associated Types

type Stream: Stream<Item = Result<Option<Req>, Error>>

The stream to be produced by the backend

type Layer

Returns the final decoration of layers

type Codec: Codec

Specifies the codec type used by the backend

Required Methods

fn poll(self, worker: &Worker<Context>) -> Poller<Self::Stream, Self::Layer>

Returns a poller that is ready for streaming

Implementors

impl<T, Ctx> Backend<Request<T, Ctx>> for RequestStream<Request<T, Ctx>>

type Stream = Pin<Box<dyn Stream<Item = Result<Option<Request<T, Ctx>>, Error>> + Send>>

type Layer = Identity

type Codec = NoopCodec<Request<T, Ctx>>

impl<T: Send + 'static + Sync> Backend<Request<T, ()>> for MemoryStorage<T>

type Stream = BackendStream<Pin<Box<dyn Stream<Item = Result<Option<Request<T, ()>>, Error>> + Send>>>

type Layer = Identity

type Codec = NoopCodec<Request<T, ()>>