Home
last modified time | relevance | path

Searched refs:cancellableContext (Results 1 – 3 of 3) sorted by relevance

/external/grpc-grpc-java/core/src/test/java/io/grpc/
DContextsTest.java195 Context.CancellableContext cancellableContext = Context.current().withCancellation(); in statusFromCancelled_returnStatusAsSetOnCtx() local
196 cancellableContext.cancel(Status.DEADLINE_EXCEEDED.withDescription("foo bar").asException()); in statusFromCancelled_returnStatusAsSetOnCtx()
197 Status status = statusFromCancelled(cancellableContext); in statusFromCancelled_returnStatusAsSetOnCtx()
205 Context.CancellableContext cancellableContext = Context.current().withCancellation(); in statusFromCancelled_shouldReturnStatusWithCauseAttached() local
207 cancellableContext.cancel(t); in statusFromCancelled_shouldReturnStatusWithCauseAttached()
208 Status status = statusFromCancelled(cancellableContext); in statusFromCancelled_shouldReturnStatusWithCauseAttached()
217 Context.CancellableContext cancellableContext = Context.current() in statusFromCancelled_TimeoutExceptionShouldMapToDeadlineExceeded() local
222 assertTrue(cancellableContext.isCancelled()); in statusFromCancelled_TimeoutExceptionShouldMapToDeadlineExceeded()
223 assertThat(cancellableContext.cancellationCause(), instanceOf(TimeoutException.class)); in statusFromCancelled_TimeoutExceptionShouldMapToDeadlineExceeded()
225 Status status = statusFromCancelled(cancellableContext); in statusFromCancelled_TimeoutExceptionShouldMapToDeadlineExceeded()
[all …]
/external/grpc-grpc-java/core/src/test/java/io/grpc/internal/
DClientCallImplTest.java580 Context.CancellableContext cancellableContext = Context.current().withCancellation(); in contextCancellationCancelsStream() local
581 Context previous = cancellableContext.attach(); in contextCancellationCancelsStream()
593 cancellableContext.detach(previous); in contextCancellationCancelsStream()
598 cancellableContext.cancel(t); in contextCancellationCancelsStream()
608 Context.CancellableContext cancellableContext = Context.current().withCancellation(); in contextAlreadyCancelledNotifiesImmediately() local
610 cancellableContext.cancel(cause); in contextAlreadyCancelledNotifiesImmediately()
611 Context previous = cancellableContext.attach(); in contextAlreadyCancelledNotifiesImmediately()
623 cancellableContext.detach(previous); in contextAlreadyCancelledNotifiesImmediately()
/external/grpc-grpc-java/context/src/test/java/io/grpc/
DContextTest.java585 Context.CancellableContext cancellableContext = in contextWithDeadlineHasDeadline() local
587 assertNotNull(cancellableContext.getDeadline()); in contextWithDeadlineHasDeadline()