Struct SeriesSubscription 

pub struct SeriesSubscription { /* private fields */ }

Series 订阅

Implementations

impl SeriesSubscription

pub async fn start(&self) -> Result<()>

启动监听

pub async fn on_update<F>(&self, handler: F)

where F: Fn(Arc<SeriesData>, Arc<UpdateInfo>) + Send + Sync + 'static,

注册更新回调

pub async fn on_new_bar<F>(&self, handler: F)

where F: Fn(Arc<SeriesData>) + Send + Sync + 'static,

注册新 K线回调

pub async fn on_bar_update<F>(&self, handler: F)

where F: Fn(Arc<SeriesData>) + Send + Sync + 'static,

注册 K线更新回调

pub async fn on_error<F>(&self, handler: F)

where F: Fn(Arc<String>) + Send + Sync + 'static,

注册错误回调

pub async fn data_stream(&self) -> impl Stream<Item = Arc<SeriesData>>

获取数据流

pub async fn close(&self) -> Result<()>

关闭订阅