Type Alias BoxedMessageStream

pub type BoxedMessageStream = BoxStream<'static, MessageStreamItem>;

Aliased Type

struct BoxedMessageStream {}

Trait Implementations

impl StreamExecutorTestExt for BoxedMessageStream

fn next_unwrap_pending(&mut self)

Asserts that the executor is pending (not ready) now.

fn next_unwrap_ready(&mut self) -> StreamExecutorResult<Message>

Asserts that the executor is ready now, returning the next message.

fn next_unwrap_ready_chunk(&mut self) -> StreamExecutorResult<StreamChunk>

Asserts that the executor is ready on a StreamChunk now, returning the next chunk.

fn next_unwrap_ready_barrier(&mut self) -> StreamExecutorResult<Barrier>

Asserts that the executor is ready on a Barrier now, returning the next barrier.

fn next_unwrap_ready_watermark(&mut self) -> StreamExecutorResult<Watermark>

Asserts that the executor is ready on a Watermark now, returning the next barrier.

fn expect_barrier<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Barrier> + Send + 'async_trait>>

where Self: Send + 'async_trait, 'life0: 'async_trait,

fn expect_chunk<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = StreamChunk> + Send + 'async_trait>>

where Self: Send + 'async_trait, 'life0: 'async_trait,

fn expect_watermark<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Watermark> + Send + 'async_trait>>

where Self: Send + 'async_trait, 'life0: 'async_trait,