Struct Stream 

pub struct Stream { /* private fields */ }

A stream of data elements with transformation capabilities.

Implementations

impl Stream

pub fn new() -> Self

Create a new stream with default configuration.

pub fn with_config(config: StreamConfig) -> Self

Create a new stream with custom configuration.

pub async fn send(&self, message: StreamMessage) -> Result<()>

Send a message to the stream.

pub async fn recv(&self) -> Result<StreamMessage>

Receive a message from the stream.

pub fn try_recv(&self) -> Result<Option<StreamMessage>>

Try to receive a message without blocking.

pub async fn watermark(&self) -> Option<DateTime<Utc>>

Get the current watermark.

pub async fn last_checkpoint(&self) -> Option<u64>

Get the last checkpoint ID.

pub async fn elements_processed(&self) -> u64

Get the number of elements processed.

pub async fn bytes_processed(&self) -> u64

Get the total bytes processed.

pub async fn is_closed(&self) -> bool

Check if the stream is closed.

pub async fn close(&self) -> Result<()>

Close the stream.

pub fn sender(&self) -> Sender<StreamMessage>

Get a clone of the sender.

pub fn receiver(&self) -> Receiver<StreamMessage>

Get a clone of the receiver.

pub fn config(&self) -> &StreamConfig

Get the stream configuration.

Trait Implementations

impl Default for Stream

fn default() -> Self

Returns the “default value” for a type.