Trait FutureQueue 

pub trait FutureQueue: Send + Sync {
    // Required methods
    fn push<'life0, 'life1, 'async_trait>(
        &'life0 self,
        push_type: PushType,
        position_in_query: usize,
        group_signature: u64,
        element_ref: &'life1 ElementReference,
        original_time: ElementTimestamp,
        due_time: ElementTimestamp,
    ) -> Pin<Box<dyn Future<Output = Result<bool, IndexError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn remove<'life0, 'async_trait>(
        &'life0 self,
        position_in_query: usize,
        group_signature: u64,
    ) -> Pin<Box<dyn Future<Output = Result<(), IndexError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn pop<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<Option<FutureElementRef>, IndexError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn peek_due_time<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<Option<ElementTimestamp>, IndexError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn clear<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<(), IndexError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

Required Methods

fn push<'life0, 'life1, 'async_trait>( &'life0 self, push_type: PushType, position_in_query: usize, group_signature: u64, element_ref: &'life1 ElementReference, original_time: ElementTimestamp, due_time: ElementTimestamp, ) -> Pin<Box<dyn Future<Output = Result<bool, IndexError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn remove<'life0, 'async_trait>( &'life0 self, position_in_query: usize, group_signature: u64, ) -> Pin<Box<dyn Future<Output = Result<(), IndexError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn pop<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<FutureElementRef>, IndexError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn peek_due_time<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<ElementTimestamp>, IndexError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn clear<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), IndexError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Implementors

impl FutureQueue for InMemoryFutureQueue

impl FutureQueue for ShadowedFutureQueue