kvarn::websocket

Trait SinkExt

pub trait SinkExt<Item>: Sink<Item> {

Show 17 methods    // Provided methods
    fn with<U, Fut, F, E>(self, f: F) -> With<Self, Item, U, Fut, F>
       where F: FnMut(U) -> Fut,
             Fut: Future<Output = Result<Item, E>>,
             E: From<Self::Error>,
             Self: Sized { ... }
    fn with_flat_map<U, St, F>(self, f: F) -> WithFlatMap<Self, Item, U, St, F>
       where F: FnMut(U) -> St,
             St: Stream<Item = Result<Item, Self::Error>>,
             Self: Sized { ... }
    fn sink_map_err<E, F>(self, f: F) -> SinkMapErr<Self, F>
       where F: FnOnce(Self::Error) -> E,
             Self: Sized { ... }
    fn sink_err_into<E>(self) -> SinkErrInto<Self, Item, E>
       where Self: Sized,
             Self::Error: