Struct ChainStreamClient 

pub struct ChainStreamClient {
    pub server_url: String,
    pub stream_url: String,
    pub stream: StreamApi,
    pub debug: bool,
    /* private fields */
}

Main ChainStream client that provides access to all SDK functionality

Example

use chainstream_sdk::ChainStreamClient;

#[tokio::main]
async fn main() {
    let client = ChainStreamClient::new("your-access-token", None);

    // Use the stream API for real-time data
    client.stream.connect().await.unwrap();

    // Subscribe to token candles
    let unsub = client.stream.subscribe_token_candles(
        "sol",
        "So11111111111111111111111111111111111111112",
        "1s",
        |candle| {
            println!("Candle: {:?}", candle);
        },
        None,
    ).await.unwrap();
}

Fields

server_url: String

Base URL for REST API

stream_url: String

WebSocket URL for Stream API

stream: StreamApi

Stream API for real-time data subscriptions

debug: bool

Debug mode flag

Implementations

impl ChainStreamClient

pub fn new( access_token: &str, options: Option<ChainStreamClientOptions>, ) -> Self

Create a new ChainStreamClient with an access token

Arguments

• access_token - The access token for authentication
• options - Optional configuration options

Example

use chainstream_sdk::{ChainStreamClient, ChainStreamClientOptions};

let client = ChainStreamClient::new("your-access-token", None);

// Or with custom options
let client = ChainStreamClient::new("your-access-token", Some(ChainStreamClientOptions {
    stream_url: Some("wss://custom-url.com/ws".to_string()),
    ..Default::default()
}));

pub fn new_with_token_provider<T: TokenProvider>( token_provider: &T, options: Option<ChainStreamClientOptions>, ) -> Self

Create a new ChainStreamClient with a token provider for dynamic token refresh

Arguments

• token_provider - A token provider that can refresh tokens
• options - Optional configuration options

pub fn get_access_token(&self) -> &str

Get the current access token

pub async fn close(&self)

Close all connections