Trait DataSource 

pub trait DataSource {
    // Required method
    fn next(&self) -> Result<Option<WebsocketFrame>, Error>;

    // Provided method
    fn into_stream(self) -> DataSourceStream<Self>
       where Self: Sized { ... }
}

Required Methods

fn next(&self) -> Result<Option<WebsocketFrame>, Error>

Provided Methods

fn into_stream(self) -> DataSourceStream<Self>

where Self: Sized,

Implementors