Struct frappe::stream::Sink

pub struct Sink<T> { /* fields omitted */ }

A source of events that feeds the streams connected to it.

Methods

impl<T> Sink<T>

pub fn new() -> Self

Creates a new sink.

pub fn stream(&self) -> Stream<T>

Creates a stream that receives the events sent to this sink.

pub fn send<'a>(&self, val: impl Into<MaybeOwned<'a, T>>) where
    T: 'a, 

Sends a value into the sink.

The value will be distributed N-1 times as reference and then one time by value, where N is the amount of streams connected to this sink.

pub fn feed<'a, I, U>(&self, iter: I) where
    I: IntoIterator<Item = U>,
    U: Into<MaybeOwned<'a, T>>,
    T: 'a, 

Sends multiple values into the sink.

pub fn send_parallel(&self, val: &T) where
    T: Sync, 

Sends a value using multiple threads.

This method sends a value to each of the Sink's connected streams simultaneously by spawning a thread for each one, then it waits for all threads to finish. The value is sent by reference, so no cloning is done.

Trait Implementations

impl<T> Default for Sink<T>

fn default() -> Self

Creates a new sink.

impl<T> Clone for Sink<T>

fn clone(&self) -> Self

Creates a copy of this sink that references the same event source.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for Sink<T>

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

Formats the value using the given formatter.