pub struct Intraday { /* private fields */ }
Expand description
Intraday is the Websocket listener to fugle wws endpoints.
Implementations§
source§impl Intraday
impl Intraday
sourcepub fn chart(&mut self) -> Result<Receiver<ChartResponse>>
pub fn chart(&mut self) -> Result<Receiver<ChartResponse>>
Listening fugle Chart endpoint.
Example:
let mut ws = IntradayBuilder::new().symbol_id("2884").odd_lot().build();
let rx = ws.chart()?;
let response = rx.recv()?;
sourcepub async fn async_chart(&mut self) -> Result<UnboundedReceiver<ChartResponse>>
pub async fn async_chart(&mut self) -> Result<UnboundedReceiver<ChartResponse>>
Listening fugle Chart endpoint.
Example:
let mut ws = IntradayBuilder::new().symbol_id("2884").odd_lot().build();
let mut rx = ws.async_chart().await?;
let response = rx.recv().await;
sourcepub fn meta(&mut self) -> Result<Receiver<MetaResponse>>
pub fn meta(&mut self) -> Result<Receiver<MetaResponse>>
Listening fugle Meta endpoint.
Example:
let mut ws = IntradayBuilder::new().symbol_id("2884").odd_lot().build();
let rx = ws.meta()?;
let response = rx.recv()?;
sourcepub async fn async_meta(&mut self) -> Result<UnboundedReceiver<MetaResponse>>
pub async fn async_meta(&mut self) -> Result<UnboundedReceiver<MetaResponse>>
Listening fugle Meta endpoint.
Example:
let mut ws = IntradayBuilder::new().symbol_id("2884").odd_lot().build();
let mut rx = ws.async_meta().await?;
let response = rx.recv().await;
sourcepub fn quote(&mut self) -> Result<Receiver<QuoteResponse>>
pub fn quote(&mut self) -> Result<Receiver<QuoteResponse>>
Listening fugle Quote endpoint.
Example:
let mut ws = IntradayBuilder::new().symbol_id("2884").odd_lot().build();
let rx = ws.quote()?;
let response = rx.recv()?;
sourcepub async fn async_quote(&mut self) -> Result<UnboundedReceiver<QuoteResponse>>
pub async fn async_quote(&mut self) -> Result<UnboundedReceiver<QuoteResponse>>
Listening fugle Quote endpoint.
Example:
let mut ws = IntradayBuilder::new().symbol_id("2884").odd_lot().build();
let mut rx = ws.async_quote().await?;
let response = rx.recv().await;