Trait Operator 

pub trait Operator<'a, I, A>
where
    A: Action<I>,
{
    // Required method
    fn subscribe<S>(&self, subscriber: S) -> Stream<I, A::Output<'a>>
       where S: Into<Subscriber<'a, I, A>>;
}

Operator.

Required Methods

fn subscribe<S>(&self, subscriber: S) -> Stream<I, A::Output<'a>>

where S: Into<Subscriber<'a, I, A>>,

Subscribe the given subscriber.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl<'a, I, A, T1, T2, T3, T4, T5, T6, T7, T8> Operator<'a, I, A> 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>)

where I: Id, A: Action<I, Inputs = (T1, T2, T3, T4, T5, T6, T7, T8)> + 'static,

fn subscribe<S>(&self, subscriber: S) -> Stream<I, A::Output<'a>>

where S: Into<Subscriber<'a, I, A>>,

impl<'a, I, A, T1, T2, T3, T4, T5, T6, T7> Operator<'a, I, A> for (Stream<I, T1>, Stream<I, T2>, Stream<I, T3>, Stream<I, T4>, Stream<I, T5>, Stream<I, T6>, Stream<I, T7>)

where I: Id, A: Action<I, Inputs = (T1, T2, T3, T4, T5, T6, T7)> + 'static,

fn subscribe<S>(&self, subscriber: S) -> Stream<I, A::Output<'a>>

where S: Into<Subscriber<'a, I, A>>,

impl<'a, I, A, T1, T2, T3, T4, T5, T6> Operator<'a, I, A> for (Stream<I, T1>, Stream<I, T2>, Stream<I, T3>, Stream<I, T4>, Stream<I, T5>, Stream<I, T6>)

where I: Id, A: Action<I, Inputs = (T1, T2, T3, T4, T5, T6)> + 'static,

fn subscribe<S>(&self, subscriber: S) -> Stream<I, A::Output<'a>>

where S: Into<Subscriber<'a, I, A>>,

impl<'a, I, A, T1, T2, T3, T4, T5> Operator<'a, I, A> for (Stream<I, T1>, Stream<I, T2>, Stream<I, T3>, Stream<I, T4>, Stream<I, T5>)

where I: Id, A: Action<I, Inputs = (T1, T2, T3, T4, T5)> + 'static,

fn subscribe<S>(&self, subscriber: S) -> Stream<I, A::Output<'a>>

where S: Into<Subscriber<'a, I, A>>,

impl<'a, I, A, T1, T2, T3, T4> Operator<'a, I, A> for (Stream<I, T1>, Stream<I, T2>, Stream<I, T3>, Stream<I, T4>)

where I: Id, A: Action<I, Inputs = (T1, T2, T3, T4)> + 'static,

fn subscribe<S>(&self, subscriber: S) -> Stream<I, A::Output<'a>>

where S: Into<Subscriber<'a, I, A>>,

impl<'a, I, A, T1, T2, T3> Operator<'a, I, A> for (Stream<I, T1>, Stream<I, T2>, Stream<I, T3>)

where I: Id, A: Action<I, Inputs = (T1, T2, T3)> + 'static,

fn subscribe<S>(&self, subscriber: S) -> Stream<I, A::Output<'a>>

where S: Into<Subscriber<'a, I, A>>,

impl<'a, I, A, T1, T2> Operator<'a, I, A> for (Stream<I, T1>, Stream<I, T2>)

where I: Id, A: Action<I, Inputs = (T1, T2)> + 'static,

fn subscribe<S>(&self, subscriber: S) -> Stream<I, A::Output<'a>>

where S: Into<Subscriber<'a, I, A>>,

Implementors

impl<'a, I, A, T> Operator<'a, I, A> for Stream<I, T>

where I: Id, A: Action<I, Inputs = (T,)> + 'static,