Struct StreamReceiver 

pub struct StreamReceiver { /* private fields */ }

Receiver half for streaming handlers.

Wraps mpsc::Receiver<String> and holds a CancellationToken guard. When this receiver is dropped, the CancellationToken is automatically cancelled, signalling the handler that the consumer has disconnected.

Implementations

impl StreamReceiver

pub async fn recv(&mut self) -> Option<String>

Receive the next stream item, or None if the stream is complete.

Trait Implementations

impl Debug for StreamReceiver

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Drop for StreamReceiver

fn drop(&mut self)

Executes the destructor for this type.