Struct StreamAsset 

pub struct StreamAsset { /* private fields */ }

Implementations

impl StreamAsset

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

pub fn new_chuncked( reciever: Receiver<WebSocketMessage>, asset: String, chunk_size: usize, ) -> Self

pub async fn recieve(&self) -> PocketResult<DataCandle>

pub async fn recieve_chunked(&self) -> PocketResult<DataCandle>

pub fn to_stream(&self) -> impl Stream<Item = PocketResult<DataCandle>> + '_

pub fn to_stream_chuncked( &self, ) -> impl Stream<Item = PocketResult<DataCandle>> + '_

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

pub fn to_stream_chuncked_static( self: Arc<Self>, ) -> impl Stream<Item = PocketResult<DataCandle>> + 'static

Trait Implementations

impl Clone for StreamAsset

fn clone(&self) -> StreamAsset

Returns a duplicate of the value.

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

Performs copy-assignment from source.