pub trait UniversalStream<S, E>: Stream<Item = Result<S, E>> + Sink<S, Error = E> + Unpin + Send + 'static { }