--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/com/go/trove/io/FastBufferedOutputStream.java	Sat Mar 21 11:00:06 2009 +0000
@@ -0,0 +1,75 @@
+/*
+ * @(#)BufferedOutputStream.java    1.27 00/02/02
+ *
+ * Copyright 1994-2000 Sun Microsystems, Inc. All Rights Reserved.
+ * 
+ * This software is the proprietary information of Sun Microsystems, Inc.  
+ * Use is subject to license terms.
+ * 
+ */
+
+package com.go.trove.io;
+
+import java.io.*;
+
+/**
+ * FastBufferedOutputStream is just a slightly modified version of
+ * {@link java.io.BufferedOutputStream}. The synchronization is gone, and so
+ * writes are faster. Refer to the original BufferedOutputStream for
+ * documentation.
+ */
+/*
+ * @author  Arthur van Hoff
+ * @version 1.27, 02/02/00
+ * @since   JDK1.0
+ */
+public class FastBufferedOutputStream extends FilterOutputStream {
+    // These fields have been renamed and made private. In the original, they
+    // are protected.
+    private byte[] mBuffer;
+    private int mCount;
+
+    public FastBufferedOutputStream(OutputStream out) {
+        this(out, 512);
+    }
+
+    public FastBufferedOutputStream(OutputStream out, int size) {
+        super(out);
+        if (size <= 0) {
+            throw new IllegalArgumentException("Buffer size <= 0");
+        }
+        mBuffer = new byte[size];
+    }
+
+    private void flushBuffer() throws IOException {
+        if (mCount > 0) {
+            out.write(mBuffer, 0, mCount);
+            mCount = 0;
+        }
+    }
+
+    public void write(int b) throws IOException {
+        if (mCount >= mBuffer.length) {
+            flushBuffer();
+        }
+        mBuffer[mCount++] = (byte)b;
+    }
+
+    public void write(byte b[], int off, int len) throws IOException {
+        if (len >= mBuffer.length) {
+            flushBuffer();
+            out.write(b, off, len);
+            return;
+        }
+        if (len > mBuffer.length - mCount) {
+            flushBuffer();
+        }
+        System.arraycopy(b, off, mBuffer, mCount, len);
+        mCount += len;
+    }
+
+    public synchronized void flush() throws IOException {
+        flushBuffer();
+        out.flush();
+    }
+}