tickrs 0.15.0

Realtime ticker data in your terminal 📈
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

use std::time::Duration;

use async_std::sync::Arc;
use futures::future::BoxFuture;

use super::*;
use crate::api::model;

/// Returns options data for a company
pub struct OptionsData {
    symbol: String,
    date: i64,
}

impl OptionsData {
    pub fn new(symbol: String, date: i64) -> OptionsData {
        OptionsData { symbol, date }
    }
}

impl AsyncTask for OptionsData {
    type Input = (String, i64);
    type Response = model::OptionsHeader;

    fn update_interval(&self) -> Option<Duration> {
        Some(Duration::from_secs(1))
    }

    fn input(&self) -> Self::Input {
        (self.symbol.clone(), self.date)
    }

    fn task<'a>(input: Arc<Self::Input>) -> BoxFuture<'a, Option<Self::Response>> {
        Box::pin(async move {
            let symbol = &input.0;
            let date = input.1;

            crate::CLIENT
                .get_options_for_expiration_date(symbol, date)
                .await
                .ok()
        })
    }
}