2 releases
0.1.2 | May 23, 2019 |
---|---|
0.1.0 | May 23, 2019 |
#13 in #socket-io
38 downloads per month
8KB
126 lines
socketio-rust-emitter
A Rust implementation of socket.io-emitter.
How to use
use chrono::Utc;
use std::thread;
use std::time::Duration;
let io = Emitter::new("127.0.0.1");
let _ = thread::spawn(move || loop {
thread::sleep(Duration::from_millis(5000));
io.clone().emit(vec!["time", &format!("{}", Utc::now())]);
}).join();
// Different constructor options.
//1. Initialize with host:port string
let io = Emitter::new("localhost:6379")
// 2. Initlize with host, port object.
let io = Emitter::new(EmitterOpts {
host: "localhost".to_owned(),
port: 6379,
..Default::default()
});
Examples
let io = Emitter::new(EmitterOpts { host: "127.0.0.1".to_owned(), port: 6379, ..Default::default() });
// sending to all clients
io.clone().emit(vec!["broadcast", /* ... */]);
// sending to all clients in "game" room
io.clone().to("game").emit(vec!["new-game", /* ... */]);
// sending to individual socketid (private message)
io.clone().to(<socketid>).emit(vec!["private", /* ... */]);
let nsp = io.clone().of("/admin");
// sending to all clients in "admin" namespace
nsp.clone().emit(vec!["namespace", /* ... */]);
// sending to all clients in "admin" namespace and in "notifications" room
nsp.clone().to("notifications").emit(vec!["namespace", /* ... */]);
Dependencies
~7.5MB
~155K SLoC