I2P_Developers/i2p.itoopie
3
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

oops, forgot to commit this one.

Browse Source
This commit is contained in:
jrandom
2004-11-21 06:13:30 +00:00
committed by zzz
parent 2b21b97277
commit 7336bf5c55
1 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
apps/streaming/java/src/net/i2p/client/streaming/MessageOutputStream.java
View File

@ -154,11 +154,10 @@ public class MessageOutputStream extends OutputStream {
ByteArray ba = null; ByteArray ba = null;
synchronized (_dataLock) { synchronized (_dataLock) {
// flush any data, but don't wait for it // flush any data, but don't wait for it
if (_valid > 0) { _dataReceiver.writeData(_buf, 0, _valid);
_dataReceiver.writeData(_buf, 0, _valid); _written += _valid;
_written += _valid; _valid = 0;
_valid = 0;
}
if (_buf != null) { if (_buf != null) {
ba = new ByteArray(_buf); ba = new ByteArray(_buf);
_buf = null; _buf = null;