BreezeSerialization implements Serialization { @Override public byte[] serialize(Object o) throws IOException { BreezeBuffer buffer = new BreezeBuffer(DEFAULT_BUFFER_SIZE); BreezeWriter.writeObject(buffer, o); buffer.flip(); return buffer.getBytes(); }  @Override byte[] serialize(Object o); @Override T deserialize(byte[] bytes, Class<T> clz); @Override byte[] serializeMulti(Object[] objects); @Override Object[] deserializeMulti(byte[] bytes, Class<?>[] classes); @Override int getSerializationNumber(); static int DEFAULT_BUFFER_SIZE; }
@Test public void serialize() throws Exception { Serialization serialization = new BreezeSerialization(); BaseSerializeTest.testCompatibility(serialization); BaseSerializeTest.testSerialization(serialization); BaseSerializeTest.testSerializeMulti(serialization); }