[−][src]Struct erdos::dataflow::callback_builder::TwoReadEightWrite

pub struct TwoReadEightWrite<S0: State, S1: State, W0: Data, W1: Data, W2: Data, W3: Data, W4: Data, W5: Data, W6: Data, W7: Data> { /* fields omitted */ }

Methods

impl<S0: State, S1: State, W0: Data, W1: Data, W2: Data, W3: Data, W4: Data, W5: Data, W6: Data, W7: Data> TwoReadEightWrite<S0, S1, W0, W1, W2, W3, W4, W5, W6, W7>[src]

pub fn new<R0: Data, R1: Data>(
    rs0: &StatefulReadStream<R0, S0>,
    rs1: &StatefulReadStream<R1, S1>,
    ws0: WriteStream<W0>,
    ws1: WriteStream<W1>,
    ws2: WriteStream<W2>,
    ws3: WriteStream<W3>,
    ws4: WriteStream<W4>,
    ws5: WriteStream<W5>,
    ws6: WriteStream<W6>,
    ws7: WriteStream<W7>
) -> Self[src]

pub fn add_watermark_callback<F: 'static + Fn(&Timestamp, &S0, &S1, &mut WriteStream<W0>, &mut WriteStream<W1>, &mut WriteStream<W2>, &mut WriteStream<W3>, &mut WriteStream<W4>, &mut WriteStream<W5>, &mut WriteStream<W6>, &mut WriteStream<W7>)>(
    &mut self,
    callback: F
)[src]

pub fn add_state<S: State>(
    &mut self,
    state: S
) -> Rc<RefCell<TwoReadEightWriteStateful<S0, S1, W0, W1, W2, W3, W4, W5, W6, W7, S>>>[src]

pub fn add_read_stream<R2: Data, S2: 'static + State>(
    &mut self,
    read_stream: &StatefulReadStream<R2, S2>
) -> Rc<RefCell<ThreeReadEightWrite<S0, S1, S2, W0, W1, W2, W3, W4, W5, W6, W7>>>[src]

Trait Implementations

impl<S0: State, S1: State, W0: Data, W1: Data, W2: Data, W3: Data, W4: Data, W5: Data, W6: Data, W7: Data> MultiStreamEventMaker for TwoReadEightWrite<S0, S1, W0, W1, W2, W3, W4, W5, W6, W7>[src]

Auto Trait Implementations

impl<S0, S1, W0, W1, W2, W3, W4, W5, W6, W7> !RefUnwindSafe for TwoReadEightWrite<S0, S1, W0, W1, W2, W3, W4, W5, W6, W7>

impl<S0, S1, W0, W1, W2, W3, W4, W5, W6, W7> !Send for TwoReadEightWrite<S0, S1, W0, W1, W2, W3, W4, W5, W6, W7>

impl<S0, S1, W0, W1, W2, W3, W4, W5, W6, W7> !Sync for TwoReadEightWrite<S0, S1, W0, W1, W2, W3, W4, W5, W6, W7>

impl<S0, S1, W0, W1, W2, W3, W4, W5, W6, W7> Unpin for TwoReadEightWrite<S0, S1, W0, W1, W2, W3, W4, W5, W6, W7>

impl<S0, S1, W0, W1, W2, W3, W4, W5, W6, W7> !UnwindSafe for TwoReadEightWrite<S0, S1, W0, W1, W2, W3, W4, W5, W6, W7>

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized, [src]

impl<T> Borrow<T> for T where
    T: ?Sized, [src]

impl<T> BorrowMut<T> for T where
    T: ?Sized, [src]

impl<T> From<T> for T[src]

impl<T> FromPy<T> for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, [src]

impl<T, U> IntoPy<U> for T where
    U: FromPy<T>, [src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, [src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, [src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.