@@ -262,35 +262,6 @@ public void transportReportStatus_stopDeliveryTrue_deadlineExceeded_notifiesTrac
262262 verify (mockTracer ).streamClosed (status );
263263 }
264264
265- @ Test
266- public void closeListener_directAssertions_stopDeliveryTrueAndFalse () {
267- ClientStreamTracer mockTracer1 = mock (ClientStreamTracer .class );
268- StatsTraceContext statsTraceCtx1 = new StatsTraceContext (new StreamTracer [] {mockTracer1 });
269- BaseTransportState state1 = new BaseTransportState (statsTraceCtx1 , transportTracer );
270- AbstractClientStream stream1 = new BaseAbstractClientStream (
271- allocator , state1 , new BaseSink () {}, statsTraceCtx1 , transportTracer );
272- stream1 .start (mockListener );
273-
274- // stopDelivery = true: clientCancelled is called before streamClosed
275- Status statusTrue = Status .CANCELLED .withDescription ("stopDelivery true" );
276- state1 .transportReportStatus (statusTrue , true , new Metadata ());
277- verify (mockTracer1 ).cancelled (statusTrue );
278- verify (mockTracer1 ).streamClosed (statusTrue );
279-
280- ClientStreamTracer mockTracer2 = mock (ClientStreamTracer .class );
281- StatsTraceContext statsTraceCtx2 = new StatsTraceContext (new StreamTracer [] {mockTracer2 });
282- BaseTransportState state2 = new BaseTransportState (statsTraceCtx2 , transportTracer );
283- AbstractClientStream stream2 = new BaseAbstractClientStream (
284- allocator , state2 , new BaseSink () {}, statsTraceCtx2 , transportTracer );
285- stream2 .start (mockListener );
286-
287- // stopDelivery = false: clientCancelled is NOT called, only streamClosed
288- Status statusFalse = Status .CANCELLED .withDescription ("stopDelivery false" );
289- state2 .transportReportStatus (statusFalse , false , new Metadata ());
290- verify (mockTracer2 , never ()).cancelled (any (Status .class ));
291- verify (mockTracer2 ).streamClosed (statusFalse );
292- }
293-
294265 @ Test
295266 public void closeListener_deferredDeframerClose_stopDeliveryFalse_delaysCloseListener () {
296267 ClientStreamTracer mockTracer = mock (ClientStreamTracer .class );
0 commit comments