Struct Stream 

pub struct Stream<R, W> { /* private fields */ }

A generic sync transport that operates on any BufRead input and Write output.

Implementations

impl<R, W> Stream<R, W>

where R: BufRead, W: Write,

pub fn new(reader: R, writer: W) -> Self

Trait Implementations

impl<C, R, W> Transport<C> for Stream<R, W>

where C: Send + Sync, R: BufRead, W: Write,

type Handler = Box<dyn Fn(&C, Value) -> Result<Value, Error> + Sync + Send>

type Output = ()

type Error = Error

fn serve( self, ctx: C, handlers: HashMap<String, Self::Handler>, ) -> Result<Self::Output, Self::Error>