Struct CronPipe 

pub struct CronPipe<Inner> { /* private fields */ }

A generic Pipe that wraps an inner type along with a RequestStream.

Trait Implementations

impl<T, Ctx, Inner> Backend<Request<T, Ctx>> for CronPipe<Inner>

where Inner: Backend<Request<T, Ctx>>,

type Stream = <Inner as Backend<Request<T, Ctx>>>::Stream

The stream to be produced by the backend

type Layer = <Inner as Backend<Request<T, Ctx>>>::Layer

Returns the final decoration of layers

type Codec = <Inner as Backend<Request<T, Ctx>>>::Codec

Specifies the codec type used by the backend

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

Returns a poller that is ready for streaming

impl<Inner: Debug> Debug for CronPipe<Inner>

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

Formats the value using the given formatter.