Trait ya_client::web::EventStreamExt

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>

Implementors

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