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

Stub mockTransport.newStream() to prevent NPE.

This commit is contained in:
Kun Zhang 2015-10-01 15:13:03 -07:00
parent a99e97791f
commit be400d3ea8
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
core/src/test/java/io/grpc/internal/ManagedChannelImplTest.java
View File

@ -295,7 +295,11 @@ public class ManagedChannelImplTest {
public void testNoDeadlockOnShutdown() {
// Force creation of transport
ClientCall<String, Integer> call = channel.newCall(method, CallOptions.DEFAULT);
call.start(mockCallListener, new Metadata());
Metadata headers = new Metadata();
ClientStream mockStream = mock(ClientStream.class);
when(mockTransport.newStream(same(method), same(headers), any(ClientStreamListener.class)))
.thenReturn(mockStream);
call.start(mockCallListener, headers);
call.cancel();
verify(mockTransport, timeout(1000)).start(transportListenerCaptor.capture());