diff options
| author | Eric Gribkoff <ericgribkoff@google.com> | 2018-03-22 12:38:42 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2018-03-22 12:38:42 -0700 |
| commit | 5337728fa7b36c79664759ff408d3469c101e324 (patch) | |
| tree | 0afece5416d2e8db406369acc84af4a6c2b31486 /okhttp | |
| parent | ca55b6f7e7ea8521543c36e062e62e394ff14716 (diff) | |
| download | grpc-grpc-java-5337728fa7b36c79664759ff408d3469c101e324.tar.gz | |
core,netty: client sends rst stream when server half-closes (#4222)
Diffstat (limited to 'okhttp')
| -rw-r--r-- | okhttp/src/main/java/io/grpc/okhttp/OkHttpClientStream.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/okhttp/src/main/java/io/grpc/okhttp/OkHttpClientStream.java b/okhttp/src/main/java/io/grpc/okhttp/OkHttpClientStream.java index 4cb6153a9..7a5ee95da 100644 --- a/okhttp/src/main/java/io/grpc/okhttp/OkHttpClientStream.java +++ b/okhttp/src/main/java/io/grpc/okhttp/OkHttpClientStream.java @@ -320,7 +320,7 @@ class OkHttpClientStream extends AbstractClientStream { @GuardedBy("lock") private void onEndOfStream() { - if (!framer().isClosed()) { + if (!isOutboundClosed()) { // If server's end-of-stream is received before client sends end-of-stream, we just send a // reset to server to fully close the server side stream. transport.finishStream(id(),null, PROCESSED, false, ErrorCode.CANCEL, null); |