Struct SyncStreamEngine 

pub struct SyncStreamEngine<A: AsyncStreamBackend + ?Sized> {
    pub rt: Handle,
    pub finished: bool,
    pub buffer: VecDeque<DcbSequencedEvent>,
    pub async_resp: Box<A>,
}

Fields

rt: Handle

finished: bool

buffer: VecDeque<DcbSequencedEvent>

async_resp: Box<A>

Implementations

impl<A: AsyncStreamBackend + ?Sized> SyncStreamEngine<A>

pub fn new(rt: Handle, async_resp: Box<A>) -> Self

pub fn next_item(&mut self) -> Option<DcbResult<DcbSequencedEvent>>

Reusable implementation for standard Iterator::next()

pub fn next_item_timeout( &mut self, timeout: Duration, ) -> Option<DcbResult<DcbSequencedEvent>>

The single, reusable implementation for IteratorWithTimeout::next_timeout()

pub fn engine_next_batch(&mut self) -> DcbResult<Vec<DcbSequencedEvent>>

Centralized next_batch logic shared by all synchronous traits

pub fn engine_next_batch_timeout( &mut self, timeout: Duration, ) -> DcbResult<Vec<DcbSequencedEvent>>

Centralized next_batch_timeout logic

pub fn engine_stop(&mut self)

Centralized stop routine