Merge pull request mongodb#31 from josephks/master

Adding BasicOutputBuffer.pipe( DataOutput out )
foursquare · May 12, 2011 · 7aae216 · 7aae216
2 parents c495cfd + b275de4
commit 7aae216
Showing 1 changed file with 20 additions and 0 deletions.
diff --git a/src/main/org/bson/io/BasicOutputBuffer.java b/src/main/org/bson/io/BasicOutputBuffer.java
@@ -6,51 +6,69 @@
 
 public class BasicOutputBuffer extends OutputBuffer {
 
+    @Override
     public void write(byte[] b){
         write( b , 0 , b.length );
     }
 
+    @Override
     public void write(byte[] b, int off, int len){
         _ensure( len );
         System.arraycopy( b , off , _buffer , _cur , len );
         _cur += len;
         _size = Math.max( _cur , _size );
     }
+    @Override
     public void write(int b){
         _ensure(1);
         _buffer[_cur++] = (byte)(0xFF&b);
         _size = Math.max( _cur , _size );
     }
 
+    @Override
     public int getPosition(){
         return _cur;
     }
+    @Override
     public void setPosition( int position ){
         _cur = position;
     }
 
+    @Override
     public void seekEnd(){
         _cur = _size;
     }
+    @Override
     public void seekStart(){
         _cur = 0;
     }
 
     /**
      * @return size of data so far
      */
+    @Override
     public int size(){
         return _size;
     }
 
     /**
      * @return bytes written
      */
+    @Override
     public int pipe( OutputStream out )
         throws IOException {
         out.write( _buffer , 0 , _size );
         return _size;
     }
+    /**
+     * @return bytes written
+     */
+    public int pipe( DataOutput out )
+        throws IOException {
+        out.write( _buffer , 0 , _size );
+        return _size;
+    }
+
 
     void _ensure( int more ){
         final int need = _cur + more;
@@ -66,10 +84,12 @@ void _ensure( int more ){
         _buffer = n;
     }
 
+    @Override
     public String asString(){
         return new String( _buffer , 0 , _size );
     }
 
+    @Override
     public String asString( String encoding )
         throws UnsupportedEncodingException {
         return new String( _buffer , 0 , _size , encoding );