Trait BackendExt 

pub trait BackendExt: Backend {
    type Codec: Codec<Self::Args, Compact = Self::Compact>;
    type Compact;
    type CompactStream: Stream<Item = Result<Option<Task<Self::Compact, Self::Context, Self::IdType>>, Self::Error>>;

    // Required method
    fn poll_compact(self, worker: &WorkerContext) -> Self::CompactStream;
}

Defines the encoding/serialization aspects of a backend.

Required Associated Types

type Codec: Codec<Self::Args, Compact = Self::Compact>

The codec used for serialization/deserialization of tasks.

type Compact

The compact representation of task arguments.

type CompactStream: Stream<Item = Result<Option<Task<Self::Compact, Self::Context, Self::IdType>>, Self::Error>>

A stream of encoded tasks provided by the backend.

Required Methods

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

Polls the backend for encoded tasks for the given worker.

Implementors

impl<Args: 'static + Send + Serialize + DeserializeOwned + Unpin> BackendExt for JsonStorage<Args>

Available on crate feature json only.

type Codec = JsonCodec<Value>

type Compact = Value

type CompactStream = Pin<Box<dyn Stream<Item = Result<Option<Task<<JsonStorage<Args> as BackendExt>::Compact, Map<String, Value>>>, SendError>> + Send>>

impl<Args: Clone + Send + 'static, Ctx: Default + 'static> BackendExt for MemoryStorage<Args, Ctx>

type Codec = IdentityCodec

type Compact = Args

type CompactStream = Pin<Box<dyn Stream<Item = Result<Option<Task<Args, <MemoryStorage<Args, Ctx> as Backend>::Context>>, <MemoryStorage<Args, Ctx> as Backend>::Error>> + Send>>