Trait Backend

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

    // Required method
    fn poll<Svc: Service<Req, Response = Res>>(
        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

Required Methods

fn poll<Svc: Service<Req, Response = Res>>( self, worker: &Worker<Context>, ) -> Poller<Self::Stream, Self::Layer>

Returns a poller that is ready for streaming

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

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

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

type Layer = Identity

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

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

type Layer = Identity