Struct sink::sink::Sink

pub struct Sink<'a, TInput, TResult, TError> { /* fields omitted */ }

Sink is a simple struct which captures a provided handler function and routes sent data into that handler

Methods

impl<'a, TInput, TResult, TError> Sink<'a, TInput, TResult, TError>

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

Builds a Sink using the provided handler

Trait Implementations

impl<'a, TInput, TResult, TError> ISink for Sink<'a, TInput, TResult, TError>

type TInput = TInput

type TResult = TResult

type TError = TError

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