Struct StreamAsset

pub struct StreamAsset { /* private fields */ }

Implementations

impl StreamAsset

pub fn new(reciever: Receiver<WebSocketMessage>, asset: String) -> StreamAsset

pub async fn recieve(&self) -> Result<DataCandle, PocketOptionError>

pub fn to_stream( &self, ) -> impl Stream<Item = Result<DataCandle, PocketOptionError>>

pub fn to_stream_static( self: Arc<StreamAsset>, ) -> impl Stream<Item = Result<DataCandle, PocketOptionError>> + 'static

Trait Implementations

impl Clone for StreamAsset

fn clone(&self) -> StreamAsset

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.