diff --git a/apps/streaming/java/src/net/i2p/client/streaming/Connection.java b/apps/streaming/java/src/net/i2p/client/streaming/Connection.java
index 2e29f2a9d..ac6e7fe65 100644
--- a/apps/streaming/java/src/net/i2p/client/streaming/Connection.java
+++ b/apps/streaming/java/src/net/i2p/client/streaming/Connection.java
@@ -462,6 +462,8 @@ public class Connection {
             if (getUnackedPacketsSent() > 0) return;
             // wtf, this shouldn't have been scheduled
             if (_options.getInactivityTimeout() <= 0) return;
+            // if one of us can't talk...
+            if ( (_closeSentOn > 0) || (_closeReceivedOn > 0) ) return;
             
             // bugger it, might as well do the hard work now
             switch (_options.getInactivityAction()) {