Skip to content

Commit a6219dd

Browse files
committed
call streamListener.messagesAvailable(messageProducer)
1 parent 59e38a9 commit a6219dd

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

core/src/test/java/io/grpc/internal/ServerCallImplTest.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -530,6 +530,9 @@ public Long parse(InputStream stream) {
530530

531531
streamListener.halfClosed();
532532
verify(callListener, never()).onHalfClose();
533+
534+
when(messageProducer.next()).thenReturn(message, (InputStream) null);
535+
streamListener.messagesAvailable(messageProducer);
533536
verify(callListener, never()).onMessage(any());
534537
}
535538

0 commit comments

Comments
 (0)