Trait IntoStreamSet 

pub trait IntoStreamSet<I, T> {
    // Required method
    fn into_stream_set(self) -> StreamSet<I, T>;
}

Conversion into StreamSet.

Required Methods

fn into_stream_set(self) -> StreamSet<I, T>

Converts an iterator of stream references into a stream set.

Examples

use zrx_stream::combinator::IntoStreamSet;
use zrx_stream::workspace::Workspace;

// Create workspace and workflow
let workspace = Workspace::<&str>::new();
let workflow = workspace.add_workflow();

// Create streams (homogeneous)
let a = workflow.add_source::<i32>();
let b = workflow.add_source::<i32>();

// Create stream set
let set = [&a, &b].into_stream_set();

Implementors

impl<'a, I, T, S> IntoStreamSet<I, T> for S

where S: IntoIterator<Item = &'a Stream<I, T>>, Stream<I, T>: 'a,

impl<I, T> IntoStreamSet<I, T> for &Stream<I, T>