summaryrefslogtreecommitdiff
path: root/src/main/java/com/orbekk/protobuf/RpcChannel.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/com/orbekk/protobuf/RpcChannel.java')
-rw-r--r--src/main/java/com/orbekk/protobuf/RpcChannel.java3
1 files changed, 3 insertions, 0 deletions
diff --git a/src/main/java/com/orbekk/protobuf/RpcChannel.java b/src/main/java/com/orbekk/protobuf/RpcChannel.java
index 90d4521..a4f1282 100644
--- a/src/main/java/com/orbekk/protobuf/RpcChannel.java
+++ b/src/main/java/com/orbekk/protobuf/RpcChannel.java
@@ -156,6 +156,9 @@ public class RpcChannel extends Thread implements
Data.Response response;
response = Data.Response.parseDelimitedFrom(
socket.getInputStream());
+ if (response == null) {
+ throw new IOException("No response.");
+ }
finishRequest(response);
}
} catch (IOException e) {