[][src]Struct aqueue::queue::AQueue

pub struct AQueue { /* fields omitted */ }

Implementations

impl AQueue[src]

pub fn new() -> AQueue[src]

pub async fn run<A, T, S, '_>(
    &'_ self,
    call: impl FnOnce(A) -> T + Send + Sync + 'static,
    arg: A
) -> AResult<S> where
    T: Future<Output = AResult<S>> + Send + Sync + 'static,
    S: 'static,
    A: Send + Sync + 'static, 
[src]

pub async fn push<T, '_>(
    &'_ self,
    __arg1: (Receiver<AResult<T>>, Box<dyn QueueItem + Send + Sync>)
) -> AResult<T>
[src]

pub async fn run_ing<'_>(&'_ self) -> AResult<()>[src]

Trait Implementations

impl Send for AQueue[src]

impl Sync for AQueue[src]

Auto Trait Implementations

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<T> From<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.