Trait ya_client::web::EventStreamExt[−][src]

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

Required methods

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

Loading content...

Implementors

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

Loading content...