@@ -0,0 +1,1059 @@
+package rx.broadcast;%0A%0Aimport java.io.ByteArrayInputStream;%0Aimport java.io.ByteArrayOutputStream;%0Aimport java.io.IOException;%0Aimport java.io.ObjectInputStream;%0Aimport java.io.ObjectOutputStream;%0A%0Apublic final class ObjectSerializer%3CT%3E implements Serializer%3CT%3E %7B%0A    @Override%0A    @SuppressWarnings(%22unchecked%22)%0A    public final T decode(final byte%5B%5D data) %7B%0A        try %7B%0A            final ObjectInputStream ois = new ObjectInputStream(new ByteArrayInputStream(data));%0A            return (T) ois.readObject();%0A        %7D catch (final ClassNotFoundException %7C IOException e) %7B%0A            throw new RuntimeException(e);%0A        %7D%0A    %7D%0A%0A    @Override%0A    public final byte%5B%5D encode(final T data) %7B%0A        try %7B%0A            final ByteArrayOutputStream baos = new ByteArrayOutputStream();%0A            final ObjectOutputStream oos = new ObjectOutputStream(baos);%0A            oos.writeObject(data);%0A            oos.flush();%0A            return baos.toByteArray();%0A        %7D catch (final IOException e) %7B%0A            throw new RuntimeException(e);%0A        %7D%0A    %7D%0A%7D%0A

Add ObjectSerializer using built-in Java I/O