Added null check for input stream on disconnect

5 years ago · c4a3c5a000
1 changed files with 3 additions and 1 deletions
--- a/common/edge-api/src/main/java/org/thingsboard/edge/rpc/EdgeGrpcClient.java
+++ b/common/edge-api/src/main/java/org/thingsboard/edge/rpc/EdgeGrpcClient.java
@ -162,7 +162,9 @@ public class EdgeGrpcClient implements EdgeRpcClient {
    public void disconnect(boolean onError) throws InterruptedException {
        if (!onError) {
            try {
-                inputStream.onCompleted();
+                if (inputStream != null) {
+                    inputStream.onCompleted();
+                }
            } catch (Exception e) {
                log.error("Exception during onCompleted", e);
            }