Struct DataStream 

pub struct DataStream<T>
where
    T: for<'de> Deserialize<'de> + Send + Sync,
{ /* private fields */ }

Stream of messages delivered to a consumer.

The message data is deserialized and typed to data type related to a command.

Implementations

impl<T> DataStream<T>

where T: for<'de> Deserialize<'de> + Send + Sync,

pub async fn next(&mut self) -> Result<Option<T>, DataStreamError>

Wait and get next message from the stream.

Returns

• Ok(Some(T)) - next message in stream.
• Ok(None) - there is no message left
• Err(DataStreamError) - message was recived but cannot be processed. A next message can be ok.

Trait Implementations

impl<T> Drop for DataStream<T>

where T: for<'de> Deserialize<'de> + Send + Sync,

fn drop(&mut self)

Executes the destructor for this type.