We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a6219dd commit 48b2b72Copy full SHA for 48b2b72
core/src/test/java/io/grpc/internal/ServerCallImplTest.java
@@ -522,10 +522,9 @@ public Long parse(InputStream stream) {
522
when(messageProducer.next()).thenReturn(message, (InputStream) null);
523
streamListener.messagesAvailable(messageProducer);
524
ArgumentCaptor<Status> statusCaptor = ArgumentCaptor.forClass(Status.class);
525
-
526
verify(stream).cancel(statusCaptor.capture());
527
Status status = statusCaptor.getValue();
528
- assertEquals(Status.RESOURCE_EXHAUSTED.getCode(), status.getCode());
+ assertEquals(Status.Code.RESOURCE_EXHAUSTED, status.getCode());
529
assertEquals("Decompressed gRPC message exceeds maximum size", status.getDescription());
530
531
streamListener.halfClosed();
0 commit comments