Trait IntoStreamTuple 

pub trait IntoStreamTuple<I> {
    type Output: StreamTuple<I>;

    // Required method
    fn into_stream_tuple(self) -> Self::Output;
}

Conversion into StreamTuple.

Required Associated Types

type Output: StreamTuple<I>

Output type of conversion.

Required Methods

fn into_stream_tuple(self) -> Self::Output

Converts a tuple of stream references into a stream tuple.

Examples

use zrx_stream::combinator::IntoStreamTuple;
use zrx_stream::workspace::Workspace;

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

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

// Create stream tuple
let tuple = (&a, &b).into_stream_tuple();

Implementations on Foreign Types

impl<I, T1> IntoStreamTuple<I> for (&Stream<I, T1>,)

type Output = (Stream<I, T1>,)

fn into_stream_tuple(self) -> Self::Output

impl<I, T1, T2> IntoStreamTuple<I> for (&Stream<I, T1>, &Stream<I, T2>)

type Output = (Stream<I, T1>, Stream<I, T2>)

fn into_stream_tuple(self) -> Self::Output

impl<I, T1, T2, T3> IntoStreamTuple<I> for (&Stream<I, T1>, &Stream<I, T2>, &Stream<I, T3>)

type Output = (Stream<I, T1>, Stream<I, T2>, Stream<I, T3>)

fn into_stream_tuple(self) -> Self::Output

impl<I, T1, T2, T3, T4> IntoStreamTuple<I> for (&Stream<I, T1>, &Stream<I, T2>, &Stream<I, T3>, &Stream<I, T4>)

type Output = (Stream<I, T1>, Stream<I, T2>, Stream<I, T3>, Stream<I, T4>)

fn into_stream_tuple(self) -> Self::Output

impl<I, T1, T2, T3, T4, T5> IntoStreamTuple<I> for (&Stream<I, T1>, &Stream<I, T2>, &Stream<I, T3>, &Stream<I, T4>, &Stream<I, T5>)

type Output = (Stream<I, T1>, Stream<I, T2>, Stream<I, T3>, Stream<I, T4>, Stream<I, T5>)

fn into_stream_tuple(self) -> Self::Output

impl<I, T1, T2, T3, T4, T5, T6> IntoStreamTuple<I> for (&Stream<I, T1>, &Stream<I, T2>, &Stream<I, T3>, &Stream<I, T4>, &Stream<I, T5>, &Stream<I, T6>)

type Output = (Stream<I, T1>, Stream<I, T2>, Stream<I, T3>, Stream<I, T4>, Stream<I, T5>, Stream<I, T6>)

fn into_stream_tuple(self) -> Self::Output

impl<I, T1, T2, T3, T4, T5, T6, T7> IntoStreamTuple<I> for (&Stream<I, T1>, &Stream<I, T2>, &Stream<I, T3>, &Stream<I, T4>, &Stream<I, T5>, &Stream<I, T6>, &Stream<I, T7>)

type Output = (Stream<I, T1>, Stream<I, T2>, Stream<I, T3>, Stream<I, T4>, Stream<I, T5>, Stream<I, T6>, Stream<I, T7>)

fn into_stream_tuple(self) -> Self::Output

impl<I, T1, T2, T3, T4, T5, T6, T7, T8> IntoStreamTuple<I> for (&Stream<I, T1>, &Stream<I, T2>, &Stream<I, T3>, &Stream<I, T4>, &Stream<I, T5>, &Stream<I, T6>, &Stream<I, T7>, &Stream<I, T8>)

type Output = (Stream<I, T1>, Stream<I, T2>, Stream<I, T3>, Stream<I, T4>, Stream<I, T5>, Stream<I, T6>, Stream<I, T7>, Stream<I, T8>)

fn into_stream_tuple(self) -> Self::Output

Implementors

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

type Output = (Stream<I, T>,)