Struct ArrayQueuePusher 

pub struct ArrayQueuePusher<T> { /* private fields */ }

A sod::Service that is sod::Retryable and pushes input to an underlying crossbeam::queue::ArrayQueue, returning the element as an error when the queue is full.

Implementations

impl<T> ArrayQueuePusher<T>

pub fn new(q: Arc<ArrayQueue<T>>) -> Self

Trait Implementations

impl<T> Retryable<T, T> for ArrayQueuePusher<T>

fn parse_retry(&self, err: T) -> Result<T, RetryError<T>>

impl<T> Service for ArrayQueuePusher<T>

type Input = T

type Output = ()

type Error = T

fn process(&self, input: T) -> Result<Self::Output, Self::Error>

Process an input, producing a Result<Self::Output, Self::Error>

fn into_mut(self) -> ServiceMut<Self>

where Self: Sized,

Convert this Service into a ServiceMut which impls MutService

fn into_async(self) -> ServiceAsync<Self>

where Self: Sized + Send + Sync + 'static,

Convert this Service into a ServiceAsync which impls AsyncService

fn into_dyn<'a>(self) -> DynService<'a, Self::Input, Self::Output, Self::Error>

where Self: Sized + 'static,

Convert this Service into a DynService