Function orkas_core::adapt_with_option
source · pub fn adapt_with_option<R, W, O>(
stream: (R, W),
option: O
) -> (impl Stream<Item = Result<Envelope>>, impl Sink<Envelope, Error = Error>)where
R: AsyncRead,
W: AsyncWrite,
O: Options + Copy,