Skip to content

Commit 6beb245

Browse files
committed
Merge remote-tracking branch 'origin/Issue_fixed_1537' into Issue_fixed_1537
# Conflicts: # core/src/test/java/io/grpc/internal/DelayedClientTransportTest.java
2 parents 696dd52 + b7df168 commit 6beb245

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -279,14 +279,14 @@ public void testNewStreamThenShutDownNow() {
279279
ClientStream stream = delayedTransport.newStream(
280280
method, new Metadata(), CallOptions.DEFAULT, tracers);
281281
stream.start(streamListener);
282-
assertEquals(1,delayedTransport.getPendingStreamsCount());
282+
assertEquals(1, delayedTransport.getPendingStreamsCount());
283283
delayedTransport.shutdownNow(Status.UNAVAILABLE);
284284
verify(transportListener).transportShutdown(any(Status.class));
285285
verify(transportListener).transportTerminated();
286286
verify(streamListener).closed(
287287
statusCaptor.capture(), any(RpcProgress.class), any(Metadata.class));
288288

289-
assertEquals(0,delayedTransport.getPendingStreamsCount());
289+
assertEquals(0, delayedTransport.getPendingStreamsCount());
290290
assertEquals(Status.Code.UNAVAILABLE, statusCaptor.getValue().getCode());
291291
}
292292

0 commit comments

Comments
 (0)