Struct ShardRunner

pub struct ShardRunner {
    pub cache: Arc<Cache>,
    pub http: Arc<Http>,
    /* private fields */
}

A runner for managing a Shard and its respective WebSocket client.

Fields

cache: Arc<Cache>

http: Arc<Http>

Implementations

impl ShardRunner

pub fn new(opt: ShardRunnerOptions) -> Self

Creates a new runner for a Shard.

pub async fn run(&mut self) -> Result<()>

Starts the runner’s loop to receive events.

This runs a loop that performs the following in each iteration:

1. checks the receiver for ShardRunnerMessages, possibly from the ShardManager, and if there is one, acts on it.

2. checks if a heartbeat should be sent to the discord Gateway, and if so, sends one.

3. attempts to retrieve a message from the WebSocket, processing it into a GatewayEvent. This will block for 100ms before assuming there is no message available.

4. Checks with the Shard to determine if the gateway event is specifying an action to take (e.g. resuming, reconnecting, heartbeating) and then performs that action, if any.

5. Dispatches the event via the Client.

6. Go back to 1.