OMGeeky/tarpc
1
0
Fork 0
mirror of https://github.com/OMGeeky/tarpc.git synced 2026-01-05 19:16:29 +01:00
Code Issues Packages Projects Releases Wiki Activity

Update naming of publisher client and server in pubsub example

Browse Source
This commit is contained in:
Tim Kuehn
2016-11-05 15:22:17 -07:00
parent 3afcfe6274
commit 68ba7505ac
1 changed files with 12 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
examples/pubsub.rs
View File

@@ -117,20 +117,24 @@ impl publisher::FutureService for Publisher {
fn main() {
let _ = env_logger::init();
let publisher = Publisher::new().listen("localhost:0".first_socket_addr()).wait().unwrap();
let publisher_addr = publisher.local_addr();
let publisher = publisher::SyncClient::connect(publisher_addr).unwrap();
let publisher_server = Publisher::new()
.listen("localhost:0".first_socket_addr())
.wait()
.unwrap();
let publisher_addr = publisher_server.local_addr();
let publisher_client = publisher::SyncClient::connect(publisher_addr).unwrap();
let subscriber1 = Subscriber::new(0);
publisher.subscribe(0, *subscriber1.local_addr()).unwrap();
publisher_client.subscribe(0, *subscriber1.local_addr()).unwrap();
let subscriber2 = Subscriber::new(1);
publisher.subscribe(1, *subscriber2.local_addr()).unwrap();
publisher_client.subscribe(1, *subscriber2.local_addr()).unwrap();
println!("Broadcasting...");
publisher.broadcast("hello to all".to_string()).unwrap();
publisher.unsubscribe(1).unwrap();
publisher.broadcast("hello again".to_string()).unwrap();
publisher_client.broadcast("hello to all".to_string()).unwrap();
publisher_client.unsubscribe(1).unwrap();
publisher_client.broadcast("hello again".to_string()).unwrap();
thread::sleep(Duration::from_millis(300));
}