diff --git a/src/dorkbox/util/serialization/SerializationManager.java b/src/dorkbox/util/serialization/SerializationManager.java index 91d513e..27ae0f4 100644 --- a/src/dorkbox/util/serialization/SerializationManager.java +++ b/src/dorkbox/util/serialization/SerializationManager.java @@ -23,10 +23,8 @@ import com.esotericsoftware.kryo.Serializer; import com.esotericsoftware.kryo.io.Input; import com.esotericsoftware.kryo.io.Output; -import io.netty.buffer.ByteBuf; - public -interface SerializationManager { +interface SerializationManager { /** * Registers the class using the lowest, next available integer ID and the {@link Kryo#getDefaultSerializer(Class) default serializer}. @@ -79,20 +77,16 @@ interface SerializationManager { /** * Waits until a kryo is available to write, using CAS operations to prevent having to synchronize. *

- * No crypto and no sequence number - *

* There is a small speed penalty if there were no kryo's available to use. */ - void write(ByteBuf buffer, Object message) throws IOException; + void write(IO buffer, Object message) throws IOException; /** * Reads an object from the buffer. - *

- * No crypto and no sequence number * * @param length should ALWAYS be the length of the expected object! */ - Object read(ByteBuf buffer, int length) throws IOException; + Object read(IO buffer, int length) throws IOException; /** * Writes the class and object using an available kryo instance diff --git a/src/dorkbox/util/storage/DefaultStorageSerializationManager.java b/src/dorkbox/util/storage/DefaultStorageSerializationManager.java index d97fead..687276c 100644 --- a/src/dorkbox/util/storage/DefaultStorageSerializationManager.java +++ b/src/dorkbox/util/storage/DefaultStorageSerializationManager.java @@ -27,7 +27,7 @@ import dorkbox.util.serialization.SerializationDefaults; import dorkbox.util.serialization.SerializationManager; import io.netty.buffer.ByteBuf; -class DefaultStorageSerializationManager implements SerializationManager { +class DefaultStorageSerializationManager implements SerializationManager { private Kryo kryo = new Kryo() {{ // we don't want logging from Kryo... Log.set(Log.LEVEL_ERROR);