diff --git a/apps/ministreaming/java/src/net/i2p/client/streaming/I2PSocketImpl.java b/apps/ministreaming/java/src/net/i2p/client/streaming/I2PSocketImpl.java
index a249b2c29..6c04d1852 100644
--- a/apps/ministreaming/java/src/net/i2p/client/streaming/I2PSocketImpl.java
+++ b/apps/ministreaming/java/src/net/i2p/client/streaming/I2PSocketImpl.java
@@ -352,7 +352,9 @@ class I2PSocketImpl implements I2PSocket {
         }
 
         public int available() {
-            return bc.getCurrentSize();
+            synchronized (bc) {
+                return bc.getCurrentSize();
+            }
         }
 
         public void queueData(byte[] data) {
@@ -366,13 +368,13 @@ class I2PSocketImpl implements I2PSocket {
                 bc.append(data, off, len);
             }
             synchronized (I2PInputStream.this) {
-                notifyAll();
+                I2PInputStream.this.notifyAll();
             }
         }
 
-        public synchronized void notifyClosed() {
+        public void notifyClosed() {
             synchronized (I2PInputStream.this) {
-                notifyAll();
+                I2PInputStream.this.notifyAll();
             }
         }