Struct Poller

pub struct Poller<S, L = Identity> {
    pub stream: S,
    pub heartbeat: BoxFuture<'static, ()>,
    pub layer: L,
    /* private fields */
}

A poller type that allows fetching from a stream and a heartbeat future that can be used to do periodic tasks

Fields

stream: S

The stream of jobs

heartbeat: BoxFuture<'static, ()>

The heartbeat for the backend

layer: L

The tower middleware provided by the backend

Implementations

impl<S> Poller<S, Identity>

pub fn new( stream: S, heartbeat: impl Future<Output = ()> + Send + 'static, ) -> Self

Build a new poller

pub fn new_with_layer<L>( stream: S, heartbeat: impl Future<Output = ()> + Send + 'static, layer: L, ) -> Poller<S, L>

Build a poller with layer

Trait Implementations

impl<S, L> Debug for Poller<S, L>

where S: Debug, L: Debug,

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

Formats the value using the given formatter.