showdown 0.26.0

Pokemon Showdown Client
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

use comparator::collections::BinaryHeap;
use comparator::{comparing, Comparator};
use futures::{SinkExt, StreamExt};
use showdown::message::{Kind, QueryResponse, Room};
use showdown::{Result, SendMessage, Stream};

#[tokio::main]
async fn main() -> Result<()> {
    let mut stream = Stream::connect("showdown").await?;
    stream
        .send(SendMessage::global_command("cmd rooms"))
        .await?;
    while let Some(message) = stream.next().await {
        if let Kind::QueryResponse(QueryResponse::Rooms(rooms)) = message?.kind() {
            println!("Top 5 most popular rooms");
            let mut rooms_heap = BinaryHeap::with_comparator(
                comparing(|r: &&Room<'_>| r.user_count)
                    .then_comparing(comparing(|r: &&Room<'_>| &r.title).reversed()),
            );
            rooms_heap.extend(rooms.iter());
            for _ in 0..5 {
                if let Some(room) = rooms_heap.pop() {
                    println!("{} with {} users", room.title, room.user_count);
                } else {
                    break;
                }
            }
            break;
        }
    }
    Ok(())
}