summaryrefslogtreecommitdiff
path: root/java/src/Ice/OutputStreamI.java
diff options
context:
space:
mode:
authorMark Spruiell <mes@zeroc.com>2004-11-08 21:30:39 +0000
committerMark Spruiell <mes@zeroc.com>2004-11-08 21:30:39 +0000
commit0a2c609553bc07209a1a545b8cf90ea7ca03a2c2 (patch)
tree14c5cf403e7f460d83d2b88e8d29d88a140b82d2 /java/src/Ice/OutputStreamI.java
parentadding --stream option (diff)
downloadice-0a2c609553bc07209a1a545b8cf90ea7ca03a2c2.tar.bz2
ice-0a2c609553bc07209a1a545b8cf90ea7ca03a2c2.tar.xz
ice-0a2c609553bc07209a1a545b8cf90ea7ca03a2c2.zip
adding support for encapsulations, pending objects
Diffstat (limited to 'java/src/Ice/OutputStreamI.java')
-rw-r--r--java/src/Ice/OutputStreamI.java26
1 files changed, 18 insertions, 8 deletions
diff --git a/java/src/Ice/OutputStreamI.java b/java/src/Ice/OutputStreamI.java
index c3b82a3f3cc..2855cb4bceb 100644
--- a/java/src/Ice/OutputStreamI.java
+++ b/java/src/Ice/OutputStreamI.java
@@ -16,7 +16,6 @@ public class OutputStreamI implements OutputStream
{
_communicator = communicator;
_os = new IceInternal.BasicOutputStream(Util.getInstance(communicator), this);
- _writeObjects = false;
}
protected void
@@ -143,7 +142,6 @@ public class OutputStreamI implements OutputStream
public void
writeObject(Ice.Object v)
{
- _writeObjects = true;
_os.writeObject(v);
}
@@ -171,14 +169,27 @@ public class OutputStreamI implements OutputStream
_os.endWriteSlice();
}
+ public void
+ startEncapsulation()
+ {
+ _os.startWriteEncaps();
+ }
+
+ public void
+ endEncapsulation()
+ {
+ _os.endWriteEncaps();
+ }
+
+ public void
+ writePendingObjects()
+ {
+ _os.writePendingObjects();
+ }
+
public byte[]
finished()
{
- if(_writeObjects)
- {
- _os.writePendingObjects();
- }
-
java.nio.ByteBuffer buf = _os.prepareWrite();
byte[] result = new byte[buf.limit()];
buf.get(result);
@@ -198,5 +209,4 @@ public class OutputStreamI implements OutputStream
private Communicator _communicator;
private IceInternal.BasicOutputStream _os;
- private boolean _writeObjects;
}