#discord #discord-api #twilight


Utility to filter wait for filtered incoming events for the Twilight ecosystem

12 unstable releases (5 breaking)

new 0.5.1 Jul 24, 2021
0.4.1 Jun 12, 2021
0.3.0 Jan 8, 2021
0.2.1 Nov 29, 2020

#44 in Asynchronous

Download history 86/week @ 2021-04-04 58/week @ 2021-04-11 47/week @ 2021-04-18 33/week @ 2021-04-25 39/week @ 2021-05-02 153/week @ 2021-05-09 65/week @ 2021-05-16 15/week @ 2021-05-23 13/week @ 2021-05-30 62/week @ 2021-06-06 80/week @ 2021-06-13 35/week @ 2021-06-20 30/week @ 2021-06-27 21/week @ 2021-07-04 34/week @ 2021-07-11 75/week @ 2021-07-18

213 downloads per month
Used in twilight

ISC license

20K SLoC


discord badge github badge license badge rust badge

Standby is a utility to wait for an event to happen based on a predicate check. For example, you may have a command that has a reaction menu of ✅ and ❌. If you want to handle a reaction to these, using something like an application-level state or event stream may not suit your use case. It may be cleaner to wait for a reaction inline to your function. This is where Twilight Standby comes in.

Standby allows you to wait for things like an event in a certain guild ([Standby::wait_for]), a new message in a channel ([Standby::wait_for_message]), a new reaction on a message ([Standby::wait_for_reaction]), and any event that might not take place in a guild, such as a new Ready event ([Standby::wait_for_event]). Each method also has a stream variant.

To use Standby, you must process events with it in your main event loop. Check out the [Standby::process] method.

When to use futures and streams

Standby has two variants of each method: a future variant and a stream variant. An example is [Standby::wait_for_message], which also has a [Standby::wait_for_message_stream] variant. The future variant is useful when you want to oneshot an event that you need to wait for. This means that if you only need to wait for one message in a channel to come in, you'd use the future variant. If you need to wait for multiple messages, such as maybe all of the messages within a minute's timespan, you'd use the [Standby::wait_for_message_stream] method.

The difference is that if you use the futures variant in a loop then you may miss some events while processing a received event. By using a stream, you won't miss any events.


At a glance

Wait for a message in channel 123 by user 456 with the content "test":

use twilight_model::{gateway::payload::MessageCreate, id::{ChannelId, UserId}};
use twilight_standby::Standby;

let standby = Standby::new();

let message = standby.wait_for_message(ChannelId(123), |event: &MessageCreate| {
    event.author.id == UserId(456) && event.content == "test"

A full example

A full sample bot connecting to the gateway, processing events, and including a handler to wait for reactions:

use futures_util::StreamExt;
use std::{env, error::Error};
use twilight_gateway::{Event, Intents, Shard};
use twilight_model::{
    id::{ChannelId, UserId},
use twilight_standby::Standby;

async fn main() -> Result<(), Box<dyn Error>> {
    // Start a shard connected to the gateway to receive events.
    let intents = Intents::GUILD_MESSAGES | Intents::GUILD_MESSAGE_REACTIONS;
    let (shard, mut events) = Shard::new(env::var("DISCORD_TOKEN")?, intents);

    let standby = Standby::new();

    while let Some(event) = events.next().await {
        // Have standby process the event, which will fulfill any futures that
        // are waiting for an event.

        match event {
            Event::MessageCreate(msg) if msg.content == "!react" => {
                tokio::spawn(react(msg.0, standby.clone()));
            _ => {},


// Wait for a reaction from the user who sent the message, and then print it
// once they react.
async fn react(msg: Message, standby: Standby) -> Result<(), Box<dyn Error + Send + Sync + 'static>> {
    let author_id = msg.author.id;

    let reaction = standby.wait_for_reaction(msg.id, move |event: &ReactionAdd| {
        event.user_id == author_id

    println!("user reacted with {:?}", reaction.emoji);


For more examples, check out each of the methods on [Standby].


~84K SLoC