fanout -> multicast (rename)

Cargo.toml

@@ -2,7 +2,7 @@
 members = ["internal/ruchei-sample"]
 
 [workspace.package]
-version = "0.0.54" # ad7038ef3b571dc133c108e14e6bb0f8cdcd812d and earlier have invalid versions
+version = "0.0.55" # ad7038ef3b571dc133c108e14e6bb0f8cdcd812d and earlier have invalid versions
 edition = "2021"
 publish = true
 license = "MIT OR Apache-2.0"

examples/echo-bufferless.rs

@@ -3,7 +3,7 @@ use futures_util::StreamExt;
 use ruchei::{
     concurrent::ConcurrentExt,
     echo::bufferless::EchoBufferless,
-    fanout::bufferless::MulticastBufferless,
+    multicast::bufferless::MulticastBufferless,
     poll_on_wake::PollOnWakeExt,
     rw_isolation::{isolation, IsolateInner, IsolateOuter},
 };

examples/echo-interleaved.rs

@@ -1,8 +1,8 @@
 use async_std::net::TcpListener;
 use futures_util::StreamExt;
 use ruchei::{
-    concurrent::ConcurrentExt, echo::interleaved::EchoInterleaved, fanout::replay::MulticastReplay,
-    poll_on_wake::PollOnWakeExt,
+    concurrent::ConcurrentExt, echo::interleaved::EchoInterleaved,
+    multicast::replay::MulticastReplay, poll_on_wake::PollOnWakeExt,
 };
 
 #[async_std::main]

examples/events.rs

@@ -23,7 +23,7 @@ use pin_project::pin_project;
 use ruchei::{
     callback::{OnClose, Start},
     concurrent::ConcurrentExt,
-    fanout::buffered::{Multicast, MulticastBuffered},
+    multicast::buffered::{Multicast, MulticastBuffered},
     pinned_extend::Extending,
     poll_on_wake::PollOnWakeExt,
     timeout_unused::{KeepAlive, TimeoutUnused, WithTimeout},

examples/group.rs

@@ -6,8 +6,8 @@ use futures_util::{future::ready, StreamExt};
 use ruchei::{
     concurrent::ConcurrentExt,
     echo::buffered::EchoBuffered,
-    fanout::replay::MulticastReplay,
     group_by_key::{Group, GroupByKey},
+    multicast::replay::MulticastReplay,
     poll_on_wake::PollOnWakeExt,
     timeout_unused::TimeoutUnused,
 };

examples/memory.rs

@@ -12,9 +12,9 @@ use futures_util::{
 use pin_project::pin_project;
 use ruchei::{
     echo::buffered::EchoBuffered,
-    fanout::buffered::MulticastBuffered,
-    fanout::bufferless::MulticastBufferless,
-    fanout::replay::MulticastReplay,
+    multicast::buffered::MulticastBuffered,
+    multicast::bufferless::MulticastBufferless,
+    multicast::replay::MulticastReplay,
     rw_isolation::{isolation, IsolateInner, IsolateOuter},
 };
 

examples/read-callback.rs

@@ -3,7 +3,8 @@ use std::{pin::pin, time::Duration};
 use async_std::{net::TcpListener, task::sleep};
 use futures_util::{SinkExt, StreamExt};
 use ruchei::{
-    concurrent::ConcurrentExt, fanout::buffered::MulticastBuffered, read_callback::ReadCallbackExt,
+    concurrent::ConcurrentExt, multicast::buffered::MulticastBuffered,
+    read_callback::ReadCallbackExt,
 };
 
 #[async_std::main]

examples/timeout.rs

@@ -3,7 +3,7 @@ use std::time::Duration;
 use async_std::{net::TcpListener, task};
 use futures_util::StreamExt;
 use ruchei::{
-    concurrent::ConcurrentExt, echo::buffered::EchoBuffered, fanout::replay::MulticastReplay,
+    concurrent::ConcurrentExt, echo::buffered::EchoBuffered, multicast::replay::MulticastReplay,
     poll_on_wake::PollOnWakeExt, timeout_unused::TimeoutUnused,
 };
 

examples/ws-buffered.rs

@@ -1,8 +1,8 @@
 use async_std::net::TcpListener;
 use futures_util::StreamExt;
 use ruchei::{
-    concurrent::ConcurrentExt, echo::buffered::EchoBuffered, fanout::buffered::MulticastBuffered,
-    poll_on_wake::PollOnWakeExt,
+    concurrent::ConcurrentExt, echo::buffered::EchoBuffered,
+    multicast::buffered::MulticastBuffered, poll_on_wake::PollOnWakeExt,
 };
 
 #[async_std::main]

examples/ws-bufferless.rs

@@ -2,7 +2,7 @@ use async_std::net::TcpListener;
 use futures_util::StreamExt;
 use ruchei::{
     concurrent::ConcurrentExt, echo::buffered::EchoBuffered,
-    fanout::bufferless::MulticastBufferless, poll_on_wake::PollOnWakeExt,
+    multicast::bufferless::MulticastBufferless, poll_on_wake::PollOnWakeExt,
 };
 
 #[async_std::main]

examples/ws-replay.rs

@@ -1,7 +1,7 @@
 use async_std::net::TcpListener;
 use futures_util::StreamExt;
 use ruchei::{
-    concurrent::ConcurrentExt, echo::buffered::EchoBuffered, fanout::replay::MulticastReplay,
+    concurrent::ConcurrentExt, echo::buffered::EchoBuffered, multicast::replay::MulticastReplay,
     poll_on_wake::PollOnWakeExt,
 };
 

src/lib.rs

@@ -1,8 +1,8 @@
 pub mod callback;
 pub mod concurrent;
 pub mod echo;
-pub mod fanout;
 pub mod group_by_key;
+pub mod multicast;
 mod owned_close;
 pub mod pinned_extend;
 pub mod poll_on_wake;