irc-async 0.1.0

async irc library
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
33
34

use futures::future::{self, FutureExt};
use futures::stream::StreamExt;
use irc_async::{Client, ClientError, Config};

type Result<T> = std::result::Result<T, ClientError>;

async fn run() -> Result<()> {
    let config = Config {
        host: "127.0.0.1".into(),
        port: 4444,
        ssl: false,
        nick: "hello".into(),
    };
    let (mut client, fut) = Client::with_config(config).await?;
    client.register().await?;

    let handler = async {
        while let Some(Ok(message)) = client.next().await {
            println!("message: {:?}", message);
            client.send(message).await.unwrap();
        }
    };

    future::join(fut, handler).map(|(first, _)| first).await?;

    Ok(())
}

#[tokio::main]
async fn main() {
    if let Err(err) = run().await {
        eprintln!("err: {:?}", err);
    }
}