Home
last modified time | relevance | path

Searched refs:cancellationListener (Results 1 – 10 of 10) sorted by relevance

/external/dagger2/java/dagger/producers/internal/
DAbstractProducer.java56 public Producer<T> newEntryPointView(CancellationListener cancellationListener) { in newEntryPointView() argument
58 result.addCancellationListener(cancellationListener); in newEntryPointView()
80 void addCancellationListener(final CancellationListener cancellationListener) { in addCancellationListener() argument
89 cancellationListener.onProducerFutureCancelled(mayInterruptIfRunning); in addCancellationListener()
DMapOfProducerProducer.java87 CancellationListener cancellationListener) { in newEntryPointView() argument
89 MapOfProducerProducer.<V>toEntryPointView(cancellationListener)); in newEntryPointView()
104 final CancellationListener cancellationListener) { in toEntryPointView() argument
108 return entryPointViewOf(input, cancellationListener); in toEntryPointView()
DDelegateProducer.java85 public Producer<T> newEntryPointView(final CancellationListener cancellationListener) {
89 return delegate.newEntryPointView(cancellationListener);
DDependencyMethodProducer.java91 public final Producer<T> newEntryPointView(final CancellationListener cancellationListener) { in newEntryPointView() argument
109 cancellationListener.onProducerFutureCancelled(true); in newEntryPointView()
DProducers.java184 Producer<T> producer, CancellationListener cancellationListener) {
188 return ((CancellableProducer<T>) producer).newEntryPointView(cancellationListener);
231 public Producer<T> newEntryPointView(CancellationListener cancellationListener) {
DCancellableProducer.java42 Producer<T> newEntryPointView(CancellationListener cancellationListener); in newEntryPointView() argument
/external/grpc-grpc-java/context/src/test/java/io/grpc/
DContextTest.java74 private Context.CancellationListener cancellationListener = new Context.CancellationListener() { field in ContextTest
137 root.addListener(cancellationListener, MoreExecutors.directExecutor()); in rootCanNeverHaveAListener()
330 base.addListener(cancellationListener, new Executor() { in exceptionOfExecutorDoesntThrow()
346 base.addListener(cancellationListener, new Executor() { in exceptionOfExecutorDoesntThrow()
367 child.addListener(cancellationListener, MoreExecutors.directExecutor()); in cascadingCancellationNotifiesChild()
410 attached.addListener(cancellationListener, MoreExecutors.directExecutor()); in cancellableContextIsAttached()
425 child.addListener(cancellationListener, MoreExecutors.directExecutor()); in cancellableContextCascadesFromCancellableParent()
443 fork.addListener(cancellationListener, MoreExecutors.directExecutor()); in nonCascadingCancellationDoesNotNotifyForked()
648 child.addListener(cancellationListener, MoreExecutors.directExecutor()); in absoluteDeadlineTriggersAndPropagates()
663 child.addListener(cancellationListener, MoreExecutors.directExecutor()); in relativeDeadlineTriggersAndPropagates()
[all …]
/external/grpc-grpc-java/context/src/main/java/io/grpc/
DContext.java460 public void addListener(final CancellationListener cancellationListener, in addListener() argument
462 checkNotNull(cancellationListener, "cancellationListener"); in addListener()
466 new ExecutableListener(executor, cancellationListener); in addListener()
490 public void removeListener(CancellationListener cancellationListener) { in removeListener() argument
497 if (listeners.get(i).listener == cancellationListener) { in removeListener()
/external/dagger2/java/dagger/producers/
DProducers.java60 public Producer<T> newEntryPointView(CancellationListener cancellationListener) { in newEntryPointView() argument
/external/grpc-grpc-java/core/src/main/java/io/grpc/internal/
DClientCallImpl.java82 private final CancellationListener cancellationListener = new ContextCancellationListener(); field in ClientCallImpl
279 context.addListener(cancellationListener, directExecutor()); in start()
318 context.removeListener(cancellationListener); in removeContextListenerAndCancelDeadlineFuture()