diff --git a/Cargo.lock b/Cargo.lock
index 353870a0e..003942b5a 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -1,3 +1,5 @@
+# This file is automatically @generated by Cargo.
+# It is not intended for manual editing.
 [[package]]
 name = "MacTypes-sys"
 version = "2.1.0"
diff --git a/src/transport/tcp.rs b/src/transport/tcp.rs
index 82f58744d..d5126c7bb 100644
--- a/src/transport/tcp.rs
+++ b/src/transport/tcp.rs
@@ -285,9 +285,11 @@ impl Sink for TcpJetSink {
                     } else {
                         debug!("0 bytes written on {}", stream.peer_addr().unwrap())
                     }
+
                     if item.is_empty() {
                         Ok(AsyncSink::Ready)
                     } else {
+                        futures::task::current().notify();
                         Ok(AsyncSink::NotReady(item))
                     }
                 }