diff --git a/Cargo.toml b/Cargo.toml index 6f34449..f58e84f 100644 --- a/Cargo.toml +++ b/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" diff --git a/examples/echo-bufferless.rs b/examples/echo-bufferless.rs index b06f7c1..2435b61 100644 --- a/examples/echo-bufferless.rs +++ b/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}, }; diff --git a/examples/echo-interleaved.rs b/examples/echo-interleaved.rs index 95228b8..28921ff 100644 --- a/examples/echo-interleaved.rs +++ b/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] diff --git a/examples/events.rs b/examples/events.rs index 434b57a..7220152 100644 --- a/examples/events.rs +++ b/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}, diff --git a/examples/group.rs b/examples/group.rs index 5a64227..b1a0020 100644 --- a/examples/group.rs +++ b/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, }; diff --git a/examples/memory.rs b/examples/memory.rs index 11e0dd7..51ad2ce 100644 --- a/examples/memory.rs +++ b/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}, }; diff --git a/examples/read-callback.rs b/examples/read-callback.rs index 5ed5d4a..de699f8 100644 --- a/examples/read-callback.rs +++ b/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] diff --git a/examples/timeout.rs b/examples/timeout.rs index b22c49a..5ddb7a2 100644 --- a/examples/timeout.rs +++ b/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, }; diff --git a/examples/ws-buffered.rs b/examples/ws-buffered.rs index b3976f2..c046790 100644 --- a/examples/ws-buffered.rs +++ b/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] diff --git a/examples/ws-bufferless.rs b/examples/ws-bufferless.rs index 177a186..dfc6195 100644 --- a/examples/ws-bufferless.rs +++ b/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] diff --git a/examples/ws-replay.rs b/examples/ws-replay.rs index 2309260..f592890 100644 --- a/examples/ws-replay.rs +++ b/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, }; diff --git a/src/lib.rs b/src/lib.rs index 94aae29..3e73d96 100644 --- a/src/lib.rs +++ b/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; diff --git a/src/fanout.rs b/src/multicast.rs similarity index 100% rename from src/fanout.rs rename to src/multicast.rs diff --git a/src/fanout/buffered.rs b/src/multicast/buffered.rs similarity index 100% rename from src/fanout/buffered.rs rename to src/multicast/buffered.rs diff --git a/src/fanout/bufferless.rs b/src/multicast/bufferless.rs similarity index 100% rename from src/fanout/bufferless.rs rename to src/multicast/bufferless.rs diff --git a/src/fanout/replay.rs b/src/multicast/replay.rs similarity index 100% rename from src/fanout/replay.rs rename to src/multicast/replay.rs