Struct xapi::Stream

pub struct Stream { /* private fields */ }

Implementations

impl Stream

pub async fn connect( url: &str, stream_session_id: String ) -> Result<Stream, Error>

pub async fn skip_delay(&self)

pub async fn get_balance(&self) -> Result<(), Error>

Examples found in repository

examples/listen-balance.rs (line 10)

async fn listen_balance(credentials: &xapi::Credentials) -> Result<(), xapi::Error> {
    let x = xapi::connect(&credentials).await?;

    x.stream.get_balance().await?;

    loop {
        let record = x.stream.listen().await?;
        println!("{:?}", record);
    }
}

pub async fn stop_balance(&self) -> Result<(), Error>

pub async fn get_candles(&self, symbol: &str) -> Result<(), Error>

Examples found in repository

examples/listen-candles.rs (line 10)

async fn listen_candles(credentials: &xapi::Credentials) -> Result<(), xapi::Error> {
    let x = xapi::connect(&credentials).await?;

    x.stream.get_candles("BITCOIN").await?;
    x.stream.get_candles("ETHEREUM").await?;

    loop {
        let record = x.stream.listen().await?;
        println!("{:?}", record);
    }
}

pub async fn stop_candles(&self, symbol: &str) -> Result<(), Error>

pub async fn get_keep_alive(&self) -> Result<(), Error>

Examples found in repository

examples/listen-keep-alive.rs (line 10)

async fn listen_keep_alive(credentials: &xapi::Credentials) -> Result<(), xapi::Error> {
    let x = xapi::connect(&credentials).await?;

    x.stream.get_keep_alive().await?;

    loop {
        let record = x.stream.listen().await?;
        println!("{:?}", record);
    }
}

pub async fn stop_keep_alive(&self) -> Result<(), Error>

pub async fn get_news(&self) -> Result<(), Error>

pub async fn stop_news(&self) -> Result<(), Error>

pub async fn get_profits(&self) -> Result<(), Error>

Examples found in repository

examples/listen-profits.rs (line 10)

async fn listen_profits(credentials: &xapi::Credentials) -> Result<(), xapi::Error> {
    let x = xapi::connect(&credentials).await?;

    x.stream.get_profits().await?;

    loop {
        let record = x.stream.listen().await?;
        println!("{:?}", record);
    }
}

pub async fn stop_profits(&self) -> Result<(), Error>

pub async fn get_tick_prices( &self, symbol: &str, min_arrival_time: isize, max_level: isize ) -> Result<(), Error>

Examples found in repository

examples/listen-tick-prices.rs (line 10)

async fn listen_tick_prices(credentials: &xapi::Credentials) -> Result<(), xapi::Error> {
    let x = xapi::connect(&credentials).await?;

    x.stream.get_tick_prices("BITCOIN", 0, 0).await?;
    x.stream.get_tick_prices("ETHEREUM", 0, 0).await?;

    loop {
        let record = x.stream.listen().await?;
        println!("{:?}", record);
    }
}

pub async fn stop_tick_prices(&self, symbol: &str) -> Result<(), Error>

pub async fn get_trades(&self) -> Result<(), Error>

pub async fn stop_trades(&self) -> Result<(), Error>

pub async fn get_trade_status(&self) -> Result<(), Error>

pub async fn stop_trade_status(&self) -> Result<(), Error>

pub async fn ping(&self) -> Result<(), Error>

pub async fn listen(&self) -> Result<Record, Error>

Examples found in repository

examples/listen-balance.rs (line 13)

async fn listen_balance(credentials: &xapi::Credentials) -> Result<(), xapi::Error> {
    let x = xapi::connect(&credentials).await?;

    x.stream.get_balance().await?;

    loop {
        let record = x.stream.listen().await?;
        println!("{:?}", record);
    }
}

examples/listen-profits.rs (line 13)

async fn listen_profits(credentials: &xapi::Credentials) -> Result<(), xapi::Error> {
    let x = xapi::connect(&credentials).await?;

    x.stream.get_profits().await?;

    loop {
        let record = x.stream.listen().await?;
        println!("{:?}", record);
    }
}

examples/listen-keep-alive.rs (line 13)

async fn listen_keep_alive(credentials: &xapi::Credentials) -> Result<(), xapi::Error> {
    let x = xapi::connect(&credentials).await?;

    x.stream.get_keep_alive().await?;

    loop {
        let record = x.stream.listen().await?;
        println!("{:?}", record);
    }
}

examples/listen-candles.rs (line 14)

async fn listen_candles(credentials: &xapi::Credentials) -> Result<(), xapi::Error> {
    let x = xapi::connect(&credentials).await?;

    x.stream.get_candles("BITCOIN").await?;
    x.stream.get_candles("ETHEREUM").await?;

    loop {
        let record = x.stream.listen().await?;
        println!("{:?}", record);
    }
}

examples/listen-tick-prices.rs (line 14)

async fn listen_tick_prices(credentials: &xapi::Credentials) -> Result<(), xapi::Error> {
    let x = xapi::connect(&credentials).await?;

    x.stream.get_tick_prices("BITCOIN", 0, 0).await?;
    x.stream.get_tick_prices("ETHEREUM", 0, 0).await?;

    loop {
        let record = x.stream.listen().await?;
        println!("{:?}", record);
    }
}

Trait Implementations

impl Clone for Stream

fn clone(&self) -> Stream

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Stream

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.