diff options
author | Alex Auvolat <alex@adnab.me> | 2022-09-12 17:19:26 +0200 |
---|---|---|
committer | Alex Auvolat <alex@adnab.me> | 2022-09-12 17:19:26 +0200 |
commit | f0326607eebcded55fd01c41895a5b6e23bac55f (patch) | |
tree | a35e1cd5a5622cdd04ce9bd44f814487b211b353 | |
parent | 0f799a7768997c37e3e1b6861c097c4cd934acde (diff) | |
download | netapp-f0326607eebcded55fd01c41895a5b6e23bac55f.tar.gz netapp-f0326607eebcded55fd01c41895a5b6e23bac55f.zip |
slightly change example
-rw-r--r-- | examples/fullmesh.rs | 11 |
1 files changed, 3 insertions, 8 deletions
diff --git a/examples/fullmesh.rs b/examples/fullmesh.rs index 972bec0..d0190ef 100644 --- a/examples/fullmesh.rs +++ b/examples/fullmesh.rs @@ -142,6 +142,7 @@ impl Example { example_field, hex::encode(id) ); + // Fake data stream with some delays in item production let stream = Box::pin(stream::iter([100, 200, 300, 400]).then(|x| async move { tokio::time::sleep(Duration::from_millis(500)).await; @@ -191,16 +192,10 @@ impl StreamingEndpointHandler<ExampleMessage> for Example { msg.msg() ); let source_stream = msg.take_stream().unwrap(); + // Return same stream with 300ms delay let new_stream = Box::pin(source_stream.then(|x| async move { - info!( - "Handler: stream got bytes {:?}", - x.as_ref().map(|b| b.len()) - ); tokio::time::sleep(Duration::from_millis(300)).await; - Ok(Bytes::from(vec![ - 10u8; - x.map(|b| b.len()).unwrap_or(1422) * 2 - ])) + x })); Resp::new(ExampleResponse { example_field: false, |