pub trait EventStreamExt<S, E>
where S: Stream<Item = Result<Bytes, E>> + Unpin + 'static, E: Into<Error>,
{ // Required method fn event_stream(self) -> EventStream<S, E>; }

Required Methods§

Implementors§

source§

impl<S, E> EventStreamExt<S, E> for S
where S: Stream<Item = Result<Bytes, E>> + Unpin + 'static, E: Into<Error>,