Struct metio::streams::Stream

pub struct Stream { /* private fields */ }

A stream is a Metio Stream. It should not be confused with streams in that are used elsewhere in Rust. This is not something you can call next on or iterate over.

Implementations

impl Stream

pub fn new(client: Metio, name: String) -> Self

pub fn get_name(&self) -> &str

pub async fn publish<I>(&self, events: I) -> Result<(), Error>

where I: IntoIterator<Item = Event>,

Push a vector of events to the stream. Every element will be pushed as a single message to the stream.

Trait Implementations

impl Clone for Stream

fn clone(&self) -> Stream

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Stream

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

Formats the value using the given formatter.