From 96023f7add59dc7d1277c3083486a1bcba0273f9 Mon Sep 17 00:00:00 2001
From: Francois Dubois <fdubois@devolutions.net>
Date: Fri, 26 Apr 2019 14:49:26 -0400
Subject: [PATCH] Notify future task to be called again even if we return
 not_ready

---
 Cargo.lock           | 2 ++
 src/transport/tcp.rs | 2 ++
 2 files changed, 4 insertions(+)

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))
                     }
                 }