A bit of simplification.

git-svn-id: svn+ssh://src.earth.threerings.net/narya/trunk@3927 542714f4-19e9-0310-aa3c-eee0fc999fb1

src/java/com/threerings/io/ObjectInputStream.java

@@ -151,7 +151,7 @@ public class ObjectInputStream extends DataInputStream
 
             // create an instance of the appropriate object
             Object target = cmap.streamer.createObject(this);
-            readBareObject(target, cmap.streamer);
+            readBareObject(target, cmap.streamer, true);
             return target;
 
         } catch (OutOfMemoryError oome) {
@@ -170,20 +170,21 @@ public class ObjectInputStream extends DataInputStream
     public void readBareObject (Object object)
         throws IOException, ClassNotFoundException
     {
-        readBareObject(object, Streamer.getStreamer(object.getClass()));
+        readBareObject(object, Streamer.getStreamer(object.getClass()), true);
     }
 
     /**
      * Reads an object from the input stream that was previously written
      * with {@link ObjectOutputStream#writeBareObject}.
      */
-    protected void readBareObject (Object object, Streamer streamer)
+    protected void readBareObject (
+            Object object, Streamer streamer, boolean useReader)
         throws IOException, ClassNotFoundException
     {
         _current = object;
         _streamer = streamer;
         try {
-            _streamer.readObject(object, this, true);
+            _streamer.readObject(object, this, useReader);
 
         } finally {
             // clear out our current object references
@@ -221,16 +222,6 @@ public class ObjectInputStream extends DataInputStream
             ", streamer=" + _streamer + "]";
     }
 
-    /**
-     * Used by a {@link Streamer} that is reading an array of {@link
-     * Streamable} instances.
-     */
-    protected void setCurrent (Streamer streamer, Object current)
-    {
-        _streamer = streamer;
-        _current = current;
-    }
-
     /** Used to map classes to numeric codes and the {@link Streamer}
      * instance used to write them. */
     protected HashIntMap _classmap;

src/java/com/threerings/io/ObjectOutputStream.java

@@ -111,7 +111,7 @@ public class ObjectOutputStream extends DataOutputStream
             writeShort(cmap.code);
         }
 
-        writeBareObject(object, cmap.streamer);
+        writeBareObject(object, cmap.streamer, true);
     }
 
     /**
@@ -127,19 +127,20 @@ public class ObjectOutputStream extends DataOutputStream
     public void writeBareObject (Object object)
         throws IOException
     {
-        writeBareObject(object, Streamer.getStreamer(object.getClass()));
+        writeBareObject(object, Streamer.getStreamer(object.getClass()), true);
     }
 
     /**
      * Write a {@link Streamable} instance without associated class metadata.
      */
-    protected void writeBareObject (Object obj, Streamer streamer)
+    protected void writeBareObject (
+            Object obj, Streamer streamer, boolean useWriter)
         throws IOException
     {
         _current = obj;
         _streamer = streamer;
         try {
-            _streamer.writeObject(obj, this, true);
+            _streamer.writeObject(obj, this, useWriter);
 
         } finally {
             _current = null;
@@ -169,16 +170,6 @@ public class ObjectOutputStream extends DataOutputStream
         _streamer.writeObject(_current, this, false);
     }
 
-    /**
-     * Used by a {@link Streamer} that is writing an array of {@link
-     * Streamable} instances.
-     */
-    protected void setCurrent (Streamer streamer, Object current)
-    {
-        _streamer = streamer;
-        _current = current;
-    }
-
     /** Used to map classes to numeric codes and the {@link Streamer}
      * instance used to write them. */
     protected HashMap _classmap;

src/java/com/threerings/io/Streamer.java

@@ -182,11 +182,9 @@ public class Streamer
                 // now write out the populated elements
                 for (int ii = 0; ii < length; ii++) {
                     Object element = Array.get(object, ii);
-                    if (element == null) {
+                    if (element != null) {
-                        continue;
+                        out.writeBareObject(element, _delegate, useWriter);
                     }
-                    out.setCurrent(_delegate, element);
-                    _delegate.writeObject(element, out, useWriter);
                 }
 
             } else {
@@ -326,13 +324,12 @@ public class Streamer
                 // elements to read
                 for (int ii = 0; ii < length; ii++) {
                     if (mask.isSet(ii)) {
-                        Object element = _delegate.createObject(in);
-                        in.setCurrent(_delegate, element);
                         if (ObjectInputStream.STREAM_DEBUG) {
                             Log.info(in.hashCode() +
                                      ": Reading fixed element '" + ii + "'.");
                         }
-                        _delegate.readObject(element, in, useReader);
+                        Object element = _delegate.createObject(in);
+                        in.readBareObject(element, _delegate, useReader);
                         Array.set(object, ii, element);
                     } else if (ObjectInputStream.STREAM_DEBUG) {
                         Log.info(in.hashCode() +