Skip to main content

WaitStrategy

kovan_queue::disruptor

Trait WaitStrategy 

Source 
pub trait WaitStrategy: Send + Sync {
    // Required methods
    fn wait_for(
        &self,
        sequence: i64,
        cursor: &Arc<dyn Sequencer>,
        dependent: &Arc<dyn Sequencer>,
        barrier: &ProcessingSequenceBarrier,
    ) -> Result<i64, AlertException>;
    fn signal_all_when_blocking(&self);
}
Expand description

Strategy for waiting for a sequence to be available.

Required Methods§

Source

fn wait_for( &self, sequence: i64, cursor: &Arc<dyn Sequencer>, dependent: &Arc<dyn Sequencer>, barrier: &ProcessingSequenceBarrier, ) -> Result<i64, AlertException>

Waits for the given sequence to be available.

Source

fn signal_all_when_blocking(&self)

Signals all waiting threads that the cursor has advanced.

Implementors§