Struct Client 

pub struct Client { /* private fields */ }

The gateway client. Manages the WebSocket connection, heartbeating, reconnection, and event dispatch.

Call start to connect. It runs until a fatal error happens (like an invalid token) and reconnects automatically on transient failures.

Implementations

impl Client

pub fn builder(token: impl Into<String>) -> ClientBuilder

Examples found in repository

examples/bot.rs (line 202)

async fn main() {
    let token = std::env::var("FLUXER_TOKEN")
        .expect("Set FLUXER_TOKEN to your bot token");

    let mut client = Client::builder(&token)
        // .api_url("http://localhost:48763/api/v1") this is for self hosted instances
        .event_handler(Handler)
        .build();

    if let Err(e) = client.start().await {
        eprintln!("Error: {}", e);
    }
}

examples/voice.rs (line 124)

async fn main() {
    let token = std::env::var("FLUXER_TOKEN")
        .expect("Set FLUXER_TOKEN to your bot token");

    let handler = Handler {
        playback: Mutex::new(None),
        voice: Mutex::new(None),
    };

    let mut client = Client::builder(&token)
        // .api_url("http://localhost:48763/api/v1") this is for self hosted instances
        .event_handler(handler)
        .build();

    if let Err(e) = client.start().await {
        eprintln!("Error: {}", e);
    }
}

pub async fn start(&mut self) -> Result<(), ClientError>

Connects to the gateway and starts processing events. Blocks forever unless a fatal error occurs.

Examples found in repository

examples/bot.rs (line 207)

async fn main() {
    let token = std::env::var("FLUXER_TOKEN")
        .expect("Set FLUXER_TOKEN to your bot token");

    let mut client = Client::builder(&token)
        // .api_url("http://localhost:48763/api/v1") this is for self hosted instances
        .event_handler(Handler)
        .build();

    if let Err(e) = client.start().await {
        eprintln!("Error: {}", e);
    }
}

examples/voice.rs (line 129)

async fn main() {
    let token = std::env::var("FLUXER_TOKEN")
        .expect("Set FLUXER_TOKEN to your bot token");

    let handler = Handler {
        playback: Mutex::new(None),
        voice: Mutex::new(None),
    };

    let mut client = Client::builder(&token)
        // .api_url("http://localhost:48763/api/v1") this is for self hosted instances
        .event_handler(handler)
        .build();

    if let Err(e) = client.start().await {
        eprintln!("Error: {}", e);
    }
}