X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ian/git?a=blobdiff_plain;f=src%2Fbin%2Fclient.rs;h=8597cfd3ba2264ccff8b81dfafe149e7f5286e80;hb=49263a58797ac3844855b9b8db267bf50cda19c2;hp=cfb632e8ce359ed2d89d643854e52aa2c0258fe2;hpb=603e896271f3acdcd68e62e664063f49408c3d93;p=hippotat.git diff --git a/src/bin/client.rs b/src/bin/client.rs index cfb632e..8597cfd 100644 --- a/src/bin/client.rs +++ b/src/bin/client.rs @@ -283,10 +283,10 @@ async fn run_client( if addr != ic.link.client.0 { throw!(PE::Dst(addr)) } Ok(()) }, - |(o,())| Ok({ rx_queue.push(o); }), + |(o,())| future::ready(Ok({ rx_queue.push(o); })), |e| Ok::<_,SlipFramesError>( { error!("{} #{}: rx discarding: {}", &ic, req_num, e); - })) + })).await { Ok(()) => reporter.lock().success(), Err(SlipFramesError::ErrorOnlyBad) => {