Struct sink::statefulsink::StatefulSink

pub struct StatefulSink<'a, TState, TInput, TResult, TError> where
    TState: Clone,  { /* fields omitted */ }

Sink implementation which owns an internal state that is made available to the provided handler when values are sent to it

Methods

impl<'a, TState, TInput, TResult, TError> StatefulSink<'a, TState, TInput, TResult, TError> where     TState: Clone,

pub fn new<F: 'a>(handler: F) -> Self where     TState: Default,     F: Fn(TState, TInput) -> Result<TResult, TError> + 'a,

Builds a StatefulSink using the default for TState

pub fn with_state<F: 'a>(state: TState, handler: F) -> Self where     F: Fn(TState, TInput) -> Result<TResult, TError> + 'a,

Builds a StatefulSink using the TState provided

Trait Implementations

impl<'a, TState, TInput, TResult, TError> ISink for StatefulSink<'a, TState, TInput, TResult, TError> where     TState: Clone,

type TInput = TInput

type TResult = TResult

type TError = TError

fn send(&self, input: Self::TInput) -> Result<Self::TResult, Self::TError>