Struct VecDequeBackend 

pub struct VecDequeBackend<T>(/* private fields */);

Available on crate feature sleep only.

Type alias for the complete in-memory backend

Trait Implementations

impl<T> Backend for VecDequeBackend<T>

where T: Send + 'static,

type Args = T

The type of arguments the backend handles.

type IdType = RandomId

The type used to uniquely identify tasks.

type Context = ()

Context associated with each task.

type Stream = Pin<Box<dyn Stream<Item = Result<Option<Task<T, (), <VecDequeBackend<T> as Backend>::IdType>>, VecDequeError>> + Send>>

A stream of tasks provided by the backend.

type Layer = Identity

The type representing backend middleware layer.

type Beat = Pin<Box<dyn Stream<Item = Result<(), VecDequeError>> + Send>>

A stream representing heartbeat signals.

type Error = VecDequeError

The error type returned by backend operations

fn heartbeat(&self, worker: &WorkerContext) -> Self::Beat

Returns a heartbeat stream for the given worker.

fn middleware(&self) -> Self::Layer

Returns the backend’s middleware layer.

fn poll(self, worker: &WorkerContext) -> Self::Stream

Polls the backend for tasks for the given worker.

impl<T> BackendExt for VecDequeBackend<T>

where T: Send + 'static + Clone,

type Codec = IdentityCodec

The codec used for serialization/deserialization of tasks.

type Compact = T

The compact representation of task arguments.

type CompactStream = <VecDequeBackend<T> as Backend>::Stream

A stream of encoded tasks provided by the backend.

fn get_queue(&self) -> Queue

Returns the queue associated with the backend.

fn poll_compact(self, worker: &WorkerContext) -> Self::CompactStream

Polls the backend for encoded tasks for the given worker.

impl<T> Clone for VecDequeBackend<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T> Debug for VecDequeBackend<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T> Sink<Task<T, (), RandomId>> for VecDequeBackend<T>

where T: Send + 'static,

type Error = VecDequeError

The type of value produced by the sink when an error occurs.

fn poll_ready( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Attempts to prepare the Sink to receive a value.

fn start_send( self: Pin<&mut Self>, item: Task<T, (), RandomId>, ) -> Result<(), Self::Error>

Begin the process of sending a value to the sink. Each call to this function must be preceded by a successful call to poll_ready which returned Poll::Ready(Ok(())).

fn poll_flush( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Flush any remaining output from this sink.

fn poll_close( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>

Flush any remaining output and close this sink, if necessary.