pub trait Node {
    type Input;
    type Output;
    fn process(&mut self, input: Vec<Self::Input>) -> Vec<Self::Output>Notable traits for Vec<u8, A>impl<A> Write for Vec<u8, A> where
    A: Allocator
; fn reset(&mut self) { ... } fn data_remaining(&self) -> usize { ... } fn add_node<N: Node<Input = Self::Output>>(
        self,
        node: N
    ) -> Connector<Self, N>
    where
        Self: Sized
, { ... } fn add_batch_fn<O, F: Fn(Vec<Self::Output>) -> Vec<O>>(
        self,
        function: F
    ) -> Connector<Self, BatchStateless<Self::Output, O, F>>
    where
        Self: Sized
, { ... } fn add_fn<O, F: Fn(Self::Output) -> O + Send + Sync>(
        self,
        function: F
    ) -> Connector<Self, SingleStateless<Self::Output, O, F>>
    where
        Self: Sized
, { ... } fn split<N3: Node<Input = Self::Output>, N4: Node<Input = Self::Output>>(
        self,
        node1: N3,
        node2: N4
    ) -> Connector<Connector<Self, Duplicator<Self::Output>>, Pair<N3, N4>>
    where
        Self: Sized,
        Self::Output: Clone
, { ... } fn pair<O1, O2, N3: Node<Input = O1>, N4: Node<Input = O2>>(
        self,
        node1: N3,
        node2: N4
    ) -> Connector<Self, Pair<N3, N4>>
    where
        Self: Sized,
        Self: Node<Output = (O1, O2)>
, { ... } }

Associated Types

Required methods

Process a batch of data

Provided methods

Reset signal propogates through pipeline

Get number of examples left

Add function to pipeline

Add function that takes a single datapoint and outputs a single datapoint

Implementations on Foreign Types

Implementors