summaryrefslogtreecommitdiffstats
path: root/tokio/src/util
diff options
context:
space:
mode:
Diffstat (limited to 'tokio/src/util')
-rw-r--r--tokio/src/util/mod.rs8
-rw-r--r--tokio/src/util/rand.rs13
2 files changed, 10 insertions, 11 deletions
diff --git a/tokio/src/util/mod.rs b/tokio/src/util/mod.rs
index fa904c3d..cd5b151d 100644
--- a/tokio/src/util/mod.rs
+++ b/tokio/src/util/mod.rs
@@ -3,7 +3,7 @@ cfg_io_driver! {
pub(crate) mod slab;
}
-#[cfg(any(feature = "rt-threaded", feature = "macros"))]
+#[cfg(any(feature = "rt-threaded", feature = "macros", feature = "stream"))]
mod rand;
cfg_rt_threaded! {
@@ -16,6 +16,6 @@ cfg_rt_threaded! {
pub(crate) use try_lock::TryLock;
}
-cfg_macros! {
- pub use rand::thread_rng_n;
-}
+#[cfg(any(feature = "macros", feature = "stream"))]
+#[cfg_attr(not(feature = "macros"), allow(unreachable_pub))]
+pub use rand::thread_rng_n;
diff --git a/tokio/src/util/rand.rs b/tokio/src/util/rand.rs
index 101f5bb6..4b72b4b1 100644
--- a/tokio/src/util/rand.rs
+++ b/tokio/src/util/rand.rs
@@ -51,15 +51,14 @@ impl FastRand {
}
}
-// Used by the select macro
-cfg_macros! {
+// Used by the select macro and `StreamMap`
+#[cfg(any(feature = "macros", feature = "stream"))]
+#[doc(hidden)]
+#[cfg_attr(not(feature = "macros"), allow(unreachable_pub))]
+pub fn thread_rng_n(n: u32) -> u32 {
thread_local! {
static THREAD_RNG: FastRand = FastRand::new(crate::loom::rand::seed());
}
- // Used by macros
- #[doc(hidden)]
- pub fn thread_rng_n(n: u32) -> u32 {
- THREAD_RNG.with(|rng| rng.fastrand_n(n))
- }
+ THREAD_RNG.with(|rng| rng.fastrand_n(n))
}