diff --git a/core/src/main/java/com/rtm516/mcxboxbroadcast/core/webrtc/CustomDatagramTransport.java b/core/src/main/java/com/rtm516/mcxboxbroadcast/core/webrtc/CustomDatagramTransport.java
index b0e5ec1..cf046fd 100644
--- a/core/src/main/java/com/rtm516/mcxboxbroadcast/core/webrtc/CustomDatagramTransport.java
+++ b/core/src/main/java/com/rtm516/mcxboxbroadcast/core/webrtc/CustomDatagramTransport.java
@@ -31,6 +31,7 @@ public int getSendLimit() {
     public int receive(byte[] buf, int off, int len, int waitMillis) throws IOException {
         if (socket.isClosed()) {
             this.close();
+            return -1;
         }
         DatagramPacket packet = new DatagramPacket(buf, off, len);
         socket.receive(packet);
@@ -41,6 +42,7 @@ public int receive(byte[] buf, int off, int len, int waitMillis) throws IOExcept
     public void send(byte[] buf, int off, int len) throws IOException {
         if (socket.isClosed()) {
             this.close();
+            return;
         }
         socket.send(new DatagramPacket(buf, off, len));
     }