Trait AsyncStreamBackend 

pub trait AsyncStreamBackend: Send + Unpin {
    // Required methods
    fn next_batch_box(
        &mut self,
    ) -> BoxFuture<'_, DcbResult<Vec<DcbSequencedEvent>>>;
    fn next_batch_timeout_box(
        &mut self,
        timeout: Duration,
    ) -> BoxFuture<'_, DcbResult<Vec<DcbSequencedEvent>>>;
    fn cancel(&mut self);
    fn check_shutdown_status(&self) -> ShutdownStatus;
}

Required Methods

fn next_batch_box(&mut self) -> BoxFuture<'_, DcbResult<Vec<DcbSequencedEvent>>>

fn next_batch_timeout_box( &mut self, timeout: Duration, ) -> BoxFuture<'_, DcbResult<Vec<DcbSequencedEvent>>>

fn cancel(&mut self)

fn check_shutdown_status(&self) -> ShutdownStatus

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl AsyncStreamBackend for dyn DcbReadResponseAsync + Send + 'static

fn next_batch_box(&mut self) -> BoxFuture<'_, DcbResult<Vec<DcbSequencedEvent>>>

fn next_batch_timeout_box( &mut self, timeout: Duration, ) -> BoxFuture<'_, DcbResult<Vec<DcbSequencedEvent>>>

fn cancel(&mut self)

fn check_shutdown_status(&self) -> ShutdownStatus

impl AsyncStreamBackend for dyn DcbSubscriptionAsync + Send + 'static

fn next_batch_box(&mut self) -> BoxFuture<'_, DcbResult<Vec<DcbSequencedEvent>>>

fn next_batch_timeout_box( &mut self, timeout: Duration, ) -> BoxFuture<'_, DcbResult<Vec<DcbSequencedEvent>>>

fn cancel(&mut self)

fn check_shutdown_status(&self) -> ShutdownStatus

Implementors