From effb8587b1ff0ef5d9deed6076d9fc4af316fc4f Mon Sep 17 00:00:00 2001 From: Hatter Jiang Date: Sat, 19 Mar 2022 23:17:40 +0800 Subject: [PATCH] chore:rename --- __concurrent/async_study/src/main.rs | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/__concurrent/async_study/src/main.rs b/__concurrent/async_study/src/main.rs index 4f34879..33a24ff 100644 --- a/__concurrent/async_study/src/main.rs +++ b/__concurrent/async_study/src/main.rs @@ -30,27 +30,27 @@ async fn main() { for _ in 0..3 { let new_stream_id = stream_id.fetch_add(1, Ordering::SeqCst); - let left_stream = create_stream(new_stream_id, right_to_left_sender.clone(), right_consumer_stream_map.clone()); - let right_stream = create_stream(new_stream_id, left_to_right_sender.clone(), left_consumer_stream_map.clone()); + let right_stream = create_stream(new_stream_id, right_to_left_sender.clone(), right_consumer_stream_map.clone()); + let left_stream = create_stream(new_stream_id, left_to_right_sender.clone(), left_consumer_stream_map.clone()); - let (left_stream_reader, mut left_stream_writer) = tokio::io::split(left_stream); let (right_stream_reader, mut right_stream_writer) = tokio::io::split(right_stream); + let (left_stream_reader, mut left_stream_writer) = tokio::io::split(left_stream); - let a = loop_read(left_stream_reader, format!("#{} left reader", new_stream_id)); - let b = loop_read(right_stream_reader, format!("#{} right reader", new_stream_id)); + let a = loop_read(right_stream_reader, format!("#{} right reader", new_stream_id)); + let b = loop_read(left_stream_reader, format!("#{} left reader", new_stream_id)); let c = tokio::spawn(async move { for i in 0..3 { sleep(Duration::from_millis(100)).await; - let _ = left_stream_writer.write_all(format!("Left message: {} - {}", new_stream_id, i).as_bytes()).await; + let _ = right_stream_writer.write_all(format!("Right send message: {} - {}", new_stream_id, i).as_bytes()).await; } - let _ = left_stream_writer.shutdown().await; + let _ = right_stream_writer.shutdown().await; }); let d = tokio::spawn(async move { for i in 0..3 { sleep(Duration::from_millis(100)).await; - let _ = right_stream_writer.write_all(format!("Right message: {} - {}", new_stream_id, i).as_bytes()).await; + let _ = left_stream_writer.write_all(format!("Left send message: {} - {}", new_stream_id, i).as_bytes()).await; } - let _ = right_stream_writer.shutdown().await; + let _ = left_stream_writer.shutdown().await; }); joins.extend([a, b, c, d]);