pub trait NjStream: Stream { fn js_then<F>(self, fut: F) -> JsThen<Self, F> where F: FnMut(Self::Item), Self: Sized, { ... } }