pep/xmpp-rs
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

echo_bot: unify send()

Browse source
This commit is contained in:
Astro 2017-07-13 01:40:14 +02:00
parent 32031a239e
commit d5768c4c78
1 changed files with 12 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

27
examples/echo_bot.rs
View file

@ -14,19 +14,22 @@ fn main() {
let (sink, stream) = client.split(); let (sink, stream) = client.split();
let mut sink = Some(sink); let mut sink = Some(sink);
let done = stream.for_each(move |event| { let mut send = move |stanza| {
sink = Some(
sink.take().
expect("sink")
.send(stanza)
.wait()
.expect("sink.send")
);
};
let done = stream.for_each(|event| {
let result: Box<Future<Item=(), Error=String>> = match event { let result: Box<Future<Item=(), Error=String>> = match event {
ClientEvent::Online => { ClientEvent::Online => {
println!("Online!"); println!("Online!");
let presence = make_presence(); let presence = make_presence();
sink = Some( send(presence);
sink.take().
expect("sink")
.send(presence)
.wait()
.expect("sink.send")
);
Box::new( Box::new(
future::ok(()) future::ok(())
) )
@ -42,13 +45,7 @@ fn main() {
match (from.as_ref(), body) { match (from.as_ref(), body) {
(Some(from), Some(body)) => { (Some(from), Some(body)) => {
let reply = make_reply(from, body); let reply = make_reply(from, body);
sink = Some( send(reply);
sink.take().
expect("sink")
.send(reply)
.wait()
.expect("sink.send")
);
}, },
_ => (), _ => (),
}; };