Struct StreamAdapter 

pub struct StreamAdapter { /* private fields */ }

A streaming data adapter backed by a tokio unbounded MPSC channel.

Unlike JsonAdapter and CsvAdapter, StreamAdapter does not implement the synchronous DataAdapter trait. Instead it exposes async and try-recv methods for consuming candles one at a time from a live data feed.

Implementations

impl StreamAdapter

pub fn new() -> (Self, UnboundedSender<Candle>)

Creates a new StreamAdapter together with the sender half that can be used to push candles into the stream.

pub async fn recv(&mut self) -> Option<Candle>

Asynchronously receives the next candle from the stream.

Returns None when the sender has been dropped and the channel is empty.

pub fn try_recv(&mut self) -> Option<Candle>

Attempts to receive a candle without blocking.

Returns None if the channel is empty or closed.