Trait EventStreamExt 

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

fn event_stream(self) -> EventStream<S, E>

Implementors

impl<S, E> EventStreamExt<S, E> for S

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