diff --git a/ntex-util/CHANGES.md b/ntex-util/CHANGES.md
index 37f88fb9..042e0171 100644
--- a/ntex-util/CHANGES.md
+++ b/ntex-util/CHANGES.md
@@ -1,5 +1,11 @@
 # Changes
 
+## [0.1.1] - 2021-04-11
+
+* next renamed to stream_recv
+
+* send renamed to sink_write
+
 ## [0.1.0] - 2021-04-04
 
 * Move utils to separate crate
diff --git a/ntex-util/Cargo.toml b/ntex-util/Cargo.toml
index dc0cd08e..db64e254 100644
--- a/ntex-util/Cargo.toml
+++ b/ntex-util/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "ntex-util"
-version = "0.1.0"
+version = "0.1.1"
 authors = ["ntex contributors <team@ntex.rs>"]
 description = "Utilities for ntex framework"
 keywords = ["network", "framework", "async", "futures"]
diff --git a/ntex-util/src/future/mod.rs b/ntex-util/src/future/mod.rs
index 4233d79a..89d7a284 100644
--- a/ntex-util/src/future/mod.rs
+++ b/ntex-util/src/future/mod.rs
@@ -45,17 +45,33 @@ where
     }
 }
 
-/// Creates a future that resolves to the next item in the stream.
+#[doc(hidden)]
 pub async fn next<S>(stream: &mut S) -> Option<S::Item>
+where
+    S: Stream + Unpin,
+{
+    stream_recv(stream).await
+}
+
+/// Creates a future that resolves to the next item in the stream.
+pub async fn stream_recv<S>(stream: &mut S) -> Option<S::Item>
 where
     S: Stream + Unpin,
 {
     poll_fn(|cx| Pin::new(&mut *stream).poll_next(cx)).await
 }
 
+#[doc(hidden)]
+pub async fn send<S, I>(sink: &mut S, item: I) -> Result<(), S::Error>
+where
+    S: Sink<I> + Unpin,
+{
+    sink_write(sink, item).await
+}
+
 /// A future that completes after the given item has been fully processed
 /// into the sink, including flushing.
-pub async fn send<S, I>(sink: &mut S, item: I) -> Result<(), S::Error>
+pub async fn sink_write<S, I>(sink: &mut S, item: I) -> Result<(), S::Error>
 where
     S: Sink<I> + Unpin,
 {