From f0326607eebcded55fd01c41895a5b6e23bac55f Mon Sep 17 00:00:00 2001 From: Alex Auvolat Date: Mon, 12 Sep 2022 17:19:26 +0200 Subject: [PATCH] slightly change example --- examples/fullmesh.rs | 11 +++-------- 1 file 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 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,