OMGeeky/tarpc
1
0
Fork 0
mirror of https://github.com/OMGeeky/tarpc.git synced 2026-02-23 15:49:54 +01:00
Code Issues Packages Projects Releases Wiki Activity

Run the new nightly cargo fmt (#156)

Browse Source
This commit is contained in:
Tim
2017-07-18 14:54:46 -07:00
committed by GitHub
parent 4dfb3a48c3
commit 5e3cf3c807
23 changed files with 587 additions and 428 deletions
Download Patch File Download Diff File Expand all files Collapse all files

55
examples/pubsub.rs
View File

@@ -74,7 +74,9 @@ struct Publisher {
impl Publisher {
fn new() -> Publisher {
Publisher { clients: Rc::new(RefCell::new(HashMap::new())) }
Publisher {
clients: Rc::new(RefCell::new(HashMap::new())),
}
}
}
@@ -99,13 +101,15 @@ impl publisher::FutureService for Publisher {
fn subscribe(&self, id: u32, address: SocketAddr) -> Self::SubscribeFut {
let clients = self.clients.clone();
Box::new(subscriber::FutureClient::connect(address, client::Options::default())
.map(move |subscriber| {
println!("Subscribing {}.", id);
clients.borrow_mut().insert(id, subscriber);
()
})
.map_err(|e| e.to_string().into()))
Box::new(
subscriber::FutureClient::connect(address, client::Options::default())
.map(move |subscriber| {
println!("Subscribing {}.", id);
clients.borrow_mut().insert(id, subscriber);
()
})
.map_err(|e| e.to_string().into()),
)
}
type UnsubscribeFut = Box<Future<Item = (), Error = Never>>;
@@ -121,9 +125,11 @@ fn main() {
let _ = env_logger::init();
let mut reactor = reactor::Core::new().unwrap();
let (publisher_handle, server) = Publisher::new()
.listen("localhost:0".first_socket_addr(),
&reactor.handle(),
server::Options::default())
.listen(
"localhost:0".first_socket_addr(),
&reactor.handle(),
server::Options::default(),
)
.unwrap();
reactor.handle().spawn(server);
@@ -131,19 +137,24 @@ fn main() {
let subscriber2 = Subscriber::listen(1, &reactor.handle(), server::Options::default());
let publisher = reactor
.run(publisher::FutureClient::connect(publisher_handle.addr(), client::Options::default()))
.run(publisher::FutureClient::connect(
publisher_handle.addr(),
client::Options::default(),
))
.unwrap();
reactor
.run(publisher
.subscribe(0, subscriber1.addr())
.and_then(|_| publisher.subscribe(1, subscriber2.addr()))
.map_err(|e| panic!(e))
.and_then(|_| {
println!("Broadcasting...");
publisher.broadcast("hello to all".to_string())
})
.and_then(|_| publisher.unsubscribe(1))
.and_then(|_| publisher.broadcast("hi again".to_string())))
.run(
publisher
.subscribe(0, subscriber1.addr())
.and_then(|_| publisher.subscribe(1, subscriber2.addr()))
.map_err(|e| panic!(e))
.and_then(|_| {
println!("Broadcasting...");
publisher.broadcast("hello to all".to_string())
})
.and_then(|_| publisher.unsubscribe(1))
.and_then(|_| publisher.broadcast("hi again".to_string())),
)
.unwrap();
thread::sleep(Duration::from_millis(300));
}