Implementations
Trait Implementations
sourceimpl<I, O, S, F: Fn(Vec<I>, &mut S) -> Vec<O>> Node for Stateful<I, O, S, F>
impl<I, O, S, F: Fn(Vec<I>, &mut S) -> Vec<O>> Node for Stateful<I, O, S, F>
type Input = I
type Output = O
sourcefn 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 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,
A: Allocator,
Process a batch of data
sourcefn data_remaining(&self) -> usize
fn data_remaining(&self) -> usize
Get number of examples left
fn add_node<N: Node<Input = Self::Output>>(self, node: N) -> Connector<Self, N> where
Self: Sized,
sourcefn 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_batch_fn<O, F: Fn(Vec<Self::Output>) -> Vec<O>>(
self,
function: F
) -> Connector<Self, BatchStateless<Self::Output, O, F>> where
Self: Sized,
Add function to pipeline
sourcefn add_fn<O, F: Fn(Self::Output) -> O + Send + Sync>(
self,
function: F
) -> Connector<Self, SingleStateless<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,
Add function that takes a single datapoint and outputs a single datapoint
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)>,
Auto Trait Implementations
impl<I, O, S, F> RefUnwindSafe for Stateful<I, O, S, F> where
F: RefUnwindSafe,
I: RefUnwindSafe,
O: RefUnwindSafe,
S: RefUnwindSafe,
impl<I, O, S, F> Send for Stateful<I, O, S, F> where
F: Send,
I: Send,
O: Send,
S: Send,
impl<I, O, S, F> Sync for Stateful<I, O, S, F> where
F: Sync,
I: Sync,
O: Sync,
S: Sync,
impl<I, O, S, F> Unpin for Stateful<I, O, S, F> where
F: Unpin,
I: Unpin,
O: Unpin,
S: Unpin,
impl<I, O, S, F> UnwindSafe for Stateful<I, O, S, F> where
F: UnwindSafe,
I: UnwindSafe,
O: UnwindSafe,
S: UnwindSafe,
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
impl<T> Pointable for T
impl<T> Pointable for T
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
fn vzip(self) -> V
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more