From 7336bf5c55f0b8001bbdcf7945a0f5254319d946 Mon Sep 17 00:00:00 2001
From: jrandom <jrandom>
Date: Sun, 21 Nov 2004 06:13:30 +0000
Subject: [PATCH] oops, forgot to commit this one.

---
 .../net/i2p/client/streaming/MessageOutputStream.java    | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git a/apps/streaming/java/src/net/i2p/client/streaming/MessageOutputStream.java b/apps/streaming/java/src/net/i2p/client/streaming/MessageOutputStream.java
index 2afa3be50..dac624168 100644
--- a/apps/streaming/java/src/net/i2p/client/streaming/MessageOutputStream.java
+++ b/apps/streaming/java/src/net/i2p/client/streaming/MessageOutputStream.java
@@ -154,11 +154,10 @@ public class MessageOutputStream extends OutputStream {
         ByteArray ba = null;
         synchronized (_dataLock) {
             // flush any data, but don't wait for it
-            if (_valid > 0) {
-                _dataReceiver.writeData(_buf, 0, _valid);
-                _written += _valid;
-                _valid = 0;
-            }
+            _dataReceiver.writeData(_buf, 0, _valid);
+            _written += _valid;
+            _valid = 0;
+            
             if (_buf != null) {
                 ba = new ByteArray(_buf);
                 _buf = null;