From a949fcd1de1ed7b59fb52254fcb92b12dfddd278 Mon Sep 17 00:00:00 2001
From: Andrea Cavalli <andrea@cavallium.it>
Date: Mon, 1 Feb 2021 10:54:00 +0100
Subject: [PATCH] Update Serializer.java and SerializerFixedBinaryLength.java

---
 .../dbengine/database/collections/Serializer.java      | 10 +++++-----
 .../collections/SerializerFixedBinaryLength.java       |  4 ++--
 2 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/src/main/java/it/cavallium/dbengine/database/collections/Serializer.java b/src/main/java/it/cavallium/dbengine/database/collections/Serializer.java
index b605581..c69f32e 100644
--- a/src/main/java/it/cavallium/dbengine/database/collections/Serializer.java
+++ b/src/main/java/it/cavallium/dbengine/database/collections/Serializer.java
@@ -2,13 +2,13 @@ package it.cavallium.dbengine.database.collections;
 
 import io.netty.buffer.ByteBuf;
 
-public interface Serializer<B> {
+public interface Serializer<A, B> {
 
-	B deserialize(ByteBuf serialized);
+	A deserialize(B serialized);
 
-	void serialize(B deserialized, ByteBuf output);
+	void serialize(A deserialized, B output);
 
-	static Serializer<ByteBuf> noop() {
+	static Serializer<ByteBuf, ByteBuf> noop() {
 		return new Serializer<>() {
 			@Override
 			public ByteBuf deserialize(ByteBuf serialized) {
@@ -23,7 +23,7 @@ public interface Serializer<B> {
 		};
 	}
 
-	static Serializer<byte[]> noopBytes() {
+	static Serializer<byte[], ByteBuf> noopBytes() {
 		return new Serializer<>() {
 			@Override
 			public byte[] deserialize(ByteBuf serialized) {
diff --git a/src/main/java/it/cavallium/dbengine/database/collections/SerializerFixedBinaryLength.java b/src/main/java/it/cavallium/dbengine/database/collections/SerializerFixedBinaryLength.java
index 5d6b60b..4199f3a 100644
--- a/src/main/java/it/cavallium/dbengine/database/collections/SerializerFixedBinaryLength.java
+++ b/src/main/java/it/cavallium/dbengine/database/collections/SerializerFixedBinaryLength.java
@@ -2,11 +2,11 @@ package it.cavallium.dbengine.database.collections;
 
 import io.netty.buffer.ByteBuf;
 
-public interface SerializerFixedBinaryLength<B> extends Serializer<B> {
+public interface SerializerFixedBinaryLength<A, B> extends Serializer<A, B> {
 
 	int getSerializedBinaryLength();
 
-	static SerializerFixedBinaryLength<ByteBuf> noop(int length) {
+	static SerializerFixedBinaryLength<ByteBuf, ByteBuf> noop(int length) {
 		return new SerializerFixedBinaryLength<>() {
 			@Override
 			public ByteBuf deserialize(ByteBuf serialized) {