diff --git a/apps/streaming/java/src/net/i2p/client/streaming/ConnectionDataReceiver.java b/apps/streaming/java/src/net/i2p/client/streaming/ConnectionDataReceiver.java
index 4acb1049ae45e31e4fbc02377de8b297bac94106..2454d5a774a210abb839efe4cc45c570d1ecac2e 100644
--- a/apps/streaming/java/src/net/i2p/client/streaming/ConnectionDataReceiver.java
+++ b/apps/streaming/java/src/net/i2p/client/streaming/ConnectionDataReceiver.java
@@ -26,6 +26,10 @@ class ConnectionDataReceiver implements MessageOutputStream.DataReceiver {
         _dummyStatus = new DummyStatus();
     }
     
+    public boolean writeInProcess() {
+        return _connection.getUnackedPacketsSent() > 0;
+    }
+    
     /**
      * Send some data through the connection, or if there is no new data, this
      * may generate a packet with a plain ACK/NACK or CLOSE, or nothing whatsoever
diff --git a/apps/streaming/java/test/net/i2p/client/streaming/MessageOutputStreamTest.java b/apps/streaming/java/test/net/i2p/client/streaming/MessageOutputStreamTest.java
index 59386c1c996dcb4d2015221bde46f770b8d3a25b..4748440ac3ca9a7a4d907a0e46b5466fcc20a58d 100644
--- a/apps/streaming/java/test/net/i2p/client/streaming/MessageOutputStreamTest.java
+++ b/apps/streaming/java/test/net/i2p/client/streaming/MessageOutputStreamTest.java
@@ -57,6 +57,7 @@ public class MessageOutputStreamTest {
             _data.write(buf, off, size);
 			return new DummyWriteStatus();
         }
+        public boolean writeInProcess() { return false; }
         public byte[] getData() { return _data.toByteArray(); }
     }