Struct ShadowedFutureQueue 

pub struct ShadowedFutureQueue { /* private fields */ }

Implementations

impl ShadowedFutureQueue

pub fn new(inner: Arc<dyn FutureQueue>) -> Self

Trait Implementations

impl FutureQueue for ShadowedFutureQueue

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,