sink 0.1.0

This crate aims to provide an abstraction for a thing which can be sent values and, immediately, return a Result indicating success / failure of receipt. As a base primitive this should enable a message oriented variant of the inbound params to the familiar imperitive Result 'and_then' composition pattern.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

mod sinkmap;

pub mod sink;
pub mod statefulsink;

pub use self::sinkmap::*;

/// The ISink trait aims to provide an abstraction for a thing which can be sent values
/// and return a Result indicating success / failure of receipt.
///
/// As a base primitive this should enable a message oriented variant of the
/// inbound params to the familiar imperitive Result 'and_then' composition pattern.
///
/// Immediately responding to send with Result<TResult, TError> enabling implementations
/// to encapsulate both sync and async processing with a sync response.
pub trait ISink {
    type TInput;
    type TResult;
    type TError;

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