diff --git a/client/src/main/java/fr/insa/clavardator/client/users/DirectPeerConnection.java b/client/src/main/java/fr/insa/clavardator/client/users/DirectPeerConnection.java index 71f8307..677b29e 100644 --- a/client/src/main/java/fr/insa/clavardator/client/users/DirectPeerConnection.java +++ b/client/src/main/java/fr/insa/clavardator/client/users/DirectPeerConnection.java @@ -15,13 +15,13 @@ public class DirectPeerConnection extends PeerConnection { } @Override - protected void send(Serializable message, @Nullable SimpleCallback callback, @Nullable ErrorCallback errorCallback) { + public void send(Serializable message, @Nullable SimpleCallback callback, @Nullable ErrorCallback errorCallback) { connection.send(message, callback, errorCallback); } @Override - protected void receive(TcpConnection.MessageReceivedCallback callback, ErrorCallback errorCallback) { + public void receive(TcpConnection.MessageReceivedCallback callback, ErrorCallback errorCallback) { connection.receive(callback, errorCallback); } diff --git a/client/src/main/java/fr/insa/clavardator/client/users/PeerConnection.java b/client/src/main/java/fr/insa/clavardator/client/users/PeerConnection.java index c386da3..e98f2da 100644 --- a/client/src/main/java/fr/insa/clavardator/client/users/PeerConnection.java +++ b/client/src/main/java/fr/insa/clavardator/client/users/PeerConnection.java @@ -8,7 +8,7 @@ import org.jetbrains.annotations.Nullable; import java.io.Serializable; public abstract class PeerConnection { - protected abstract void send(Serializable message, @Nullable SimpleCallback calback, @Nullable ErrorCallback errorCallback); + public abstract void send(Serializable message, @Nullable SimpleCallback calback, @Nullable ErrorCallback errorCallback); /** * Subscribe to this user messages. @@ -17,7 +17,7 @@ public abstract class PeerConnection { * * @param errorCallback Callback on error */ - protected abstract void receive(TcpConnection.MessageReceivedCallback callback, ErrorCallback errorCallback); + public abstract void receive(TcpConnection.MessageReceivedCallback callback, ErrorCallback errorCallback); /** * Close the connection and set state to disconnected diff --git a/client/src/main/java/fr/insa/clavardator/client/users/ProxyPeerConnection.java b/client/src/main/java/fr/insa/clavardator/client/users/ProxyPeerConnection.java index 9269a40..e110716 100644 --- a/client/src/main/java/fr/insa/clavardator/client/users/ProxyPeerConnection.java +++ b/client/src/main/java/fr/insa/clavardator/client/users/ProxyPeerConnection.java @@ -18,13 +18,13 @@ public class ProxyPeerConnection extends PeerConnection { } @Override - protected void send(Serializable message, @Nullable SimpleCallback callback, @Nullable ErrorCallback errorCallback) { + public void send(Serializable message, @Nullable SimpleCallback callback, @Nullable ErrorCallback errorCallback) { proxy.send(message, callback, errorCallback); } @Override - protected void receive(TcpConnection.MessageReceivedCallback callback, ErrorCallback errorCallback) { + public void receive(TcpConnection.MessageReceivedCallback callback, ErrorCallback errorCallback) { proxy.receive(userId, callback, errorCallback); }