diff --git a/android/src/main/java/com/asterinet/react/tcpsocket/TcpSocketClient.java b/android/src/main/java/com/asterinet/react/tcpsocket/TcpSocketClient.java index 5c245bb..d08fc1b 100644 --- a/android/src/main/java/com/asterinet/react/tcpsocket/TcpSocketClient.java +++ b/android/src/main/java/com/asterinet/react/tcpsocket/TcpSocketClient.java @@ -103,6 +103,10 @@ public void write(final int msgId, final byte[] data) { writeExecutor.execute(new Runnable() { @Override public void run() { + if (socket == null) { + receiverListener.onError(getId(), new IOException("Attempted to write to closed socket")); + return; + } try { socket.getOutputStream().write(data); receiverListener.onWritten(getId(), msgId, null);