Struct FnSink 

pub struct FnSink<F, T, E> { /* private fields */ }

Sink adapter over a closure.

Example

use pipe_io::sink::{FnSink, Sink};

let mut total = 0u64;
{
    let mut s = FnSink::new(|item: u64| -> Result<(), &'static str> {
        total += item;
        Ok(())
    });
    s.write(1).unwrap();
    s.write(2).unwrap();
    s.write(3).unwrap();
}
assert_eq!(total, 6);

Implementations

impl<F, T, E> FnSink<F, T, E>

where F: FnMut(T) -> Result<(), E>,

pub fn new(func: F) -> Self

Wrap a closure into a sink.

Trait Implementations

impl<F, T, E> Sink for FnSink<F, T, E>

where F: FnMut(T) -> Result<(), E>, E: StageError, T: 'static,

type Item = T

Type of item this sink accepts.

type Error = E

Error type the sink can return.

fn write(&mut self, item: Self::Item) -> Result<(), Self::Error>

Write a single item.

fn flush(&mut self) -> Result<(), Self::Error>

Flush any buffered output. Default impl does nothing.

fn close(&mut self) -> Result<(), Self::Error>

Release any resources. Default impl does nothing.