Struct ConsumerStream 

pub struct ConsumerStream<T: Send + Sync + 'static> { /* private fields */ }

Wraps a MessageConsumer as a Stream<(), Message<T>>.

Calling Stream::execute returns a backpressure-aware stream that receives one message at a time. Use consumer_as_bounded_stream when the stream should complete after a fixed number of messages.

Trait Implementations

impl<T: Send + Sync + 'static> Provider for ConsumerStream<T>

fn name(&self) -> &'static str

Stable name identifying this provider instance (used in logs and spans).

impl<T: Send + Sync + Clone + 'static> Stream<(), Message<T>> for ConsumerStream<T>

async fn execute(&self, _input: ()) -> AppResult<BoxStream<Message<T>>>

Execute the request and return a stream of responses.