Struct kraken_ws_client::client::PublicClient

pub struct PublicClient { /* private fields */ }

Implementations

impl PublicClient

pub fn book_delta_events(&mut self) -> impl Stream<Item = BookEvent>

Examples found in repository

examples/book.rs (line 15)

async fn main() {
    let mut client = kraken_ws_client::connect_public()
        .await
        .expect("cannot connect");

    client
        .send(SubscribeBookRequest::symbol("BTC/USD").depth(Depth::D10))
        .await
        .expect("cannot send request");

    while let Some(event) = client.book_delta_events().next().await {
        dbg!(&event);
    }
}

impl PublicClient

pub fn instrument_events(&mut self) -> impl Stream<Item = InstrumentEvent>

impl PublicClient

pub fn ticker_events(&mut self) -> impl Stream<Item = TickerEvent>

Examples found in repository

examples/ticker.rs (line 15)

async fn main() {
    let mut client = kraken_ws_client::connect_public()
        .await
        .expect("cannot connect");

    client
        .send(SubscribeTickerRequest::symbol("BTC/USD"))
        .await
        .expect("cannot send request");

    while let Some(event) = client.ticker_events().next().await {
        dbg!(&event);
    }
}

impl PublicClient

pub fn trade_events(&mut self) -> impl Stream<Item = TradeEvent>

impl PublicClient

pub fn ohlc_events(&mut self) -> impl Stream<Item = OhlcEvent>

impl PublicClient

pub async fn connect() -> Result<Self>

pub async fn send<P>(&mut self, req: PublicRequest<P>) -> Result<()>

where P: Serialize,

Examples found in repository

examples/ticker.rs (line 11)

async fn main() {
    let mut client = kraken_ws_client::connect_public()
        .await
        .expect("cannot connect");

    client
        .send(SubscribeTickerRequest::symbol("BTC/USD"))
        .await
        .expect("cannot send request");

    while let Some(event) = client.ticker_events().next().await {
        dbg!(&event);
    }
}

examples/book.rs (line 11)

async fn main() {
    let mut client = kraken_ws_client::connect_public()
        .await
        .expect("cannot connect");

    client
        .send(SubscribeBookRequest::symbol("BTC/USD").depth(Depth::D10))
        .await
        .expect("cannot send request");

    while let Some(event) = client.book_delta_events().next().await {
        dbg!(&event);
    }
}

pub fn messages(&mut self) -> Receiver<String>

Trait Implementations

impl Debug for PublicClient

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

Formats the value using the given formatter.