From 53cd3335316e70861fdb99ca22867e06db4da2e0 Mon Sep 17 00:00:00 2001 From: Jakob Buchgraber Date: Fri, 3 Jun 2016 07:27:57 +0200 Subject: [PATCH] core: add test for complete() without close() exception in AbstractServerStream. Fixes #615 --- .../io/grpc/internal/AbstractServerStreamTest.java | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/core/src/test/java/io/grpc/internal/AbstractServerStreamTest.java b/core/src/test/java/io/grpc/internal/AbstractServerStreamTest.java index 0e3e82220f..ff98336ee5 100644 --- a/core/src/test/java/io/grpc/internal/AbstractServerStreamTest.java +++ b/core/src/test/java/io/grpc/internal/AbstractServerStreamTest.java @@ -95,6 +95,16 @@ public class AbstractServerStreamTest { verify(streamListener, times(0)).messageRead(any(InputStream.class)); } + /** + * Test for issue https://github.com/grpc/grpc-java/issues/615 + */ + @Test + public void completeWithoutClose() { + stream.transportState().setListener(new ServerStreamListenerBase()); + // Test that it doesn't throw an exception + stream.transportState().complete(); + } + @Test public void setListener_setOnlyOnce() {