risclient 0.1.1

An extremely simple streaming client for the RIPE RIS-Live service.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use risclient::*;

#[tokio::main]
async fn main() {
    println!("Creating RIS client");
    let mut client = match RisClient::default() {
	Ok(client) => client,
	Err(e) => panic!("failed to create client: {:?}", e)
    };
    println!("Connecting to stream");
    let rx = match client.stream().await {
	Ok(tup) => tup,
	Err(e) => panic!("Failed to stream RIS messages: {:?}", e)
    };
    println!("Streaming responses");
    loop {
	let data = match rx.recv() {
	    Ok(message) => message,
	    Err(e) => panic!("receive error: {:?}", e)
	};
	println!("message: {:?}\r", data);
    }
}