grpc
/
grpc-java
mirror of https://github.com/grpc/grpc-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

core: add test for complete() without close() exception in AbstractServerStream. Fixes #615

This commit is contained in:
Jakob Buchgraber 2016-06-03 07:27:57 +02:00
parent 0021e063f2
commit 53cd333531
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
core/src/test/java/io/grpc/internal/AbstractServerStreamTest.java
View File

@ -95,6 +95,16 @@ public class AbstractServerStreamTest {
verify(streamListener, times(0)).messageRead(any(InputStream.class)); 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 @Test
public void setListener_setOnlyOnce() { public void setListener_setOnlyOnce() {