package galileo.test.through;

import java.io.IOException;

import galileo.event.Event;
import galileo.serialization.SerializationInputStream;
import galileo.serialization.SerializationOutputStream;

class ThroughputMessage implements Event {

    private byte[] payload;

    public ThroughputMessage(int size) {
        payload = new byte[size];
    }

    public byte[] getPayload() {
        return payload;
    }

    @Deserialize
    public ThroughputMessage(SerializationInputStream in)
    throws IOException {
        payload = in.readField();
    }

    @Override
    public void serialize(SerializationOutputStream out)
    throws IOException {
        out.writeField(payload);
    }
}

@@ -193,16 +193,23 @@
 tream;%0A%0A
+public 
 class Th

Make ThroughputMessage public