Searched refs:cancellationListener (Results 1 – 11 of 11) sorted by relevance
56 public Producer<T> newEntryPointView(CancellationListener cancellationListener) { in newEntryPointView() argument58 result.addCancellationListener(cancellationListener); in newEntryPointView()80 void addCancellationListener(final CancellationListener cancellationListener) { in addCancellationListener() argument89 cancellationListener.onProducerFutureCancelled(mayInterruptIfRunning); in addCancellationListener()
87 CancellationListener cancellationListener) { in newEntryPointView() argument89 MapOfProducerProducer.<V>toEntryPointView(cancellationListener)); in newEntryPointView()104 final CancellationListener cancellationListener) { in toEntryPointView() argument108 return entryPointViewOf(input, cancellationListener); in toEntryPointView()
85 public Producer<T> newEntryPointView(final CancellationListener cancellationListener) {89 return delegate.newEntryPointView(cancellationListener);
91 public final Producer<T> newEntryPointView(final CancellationListener cancellationListener) { in newEntryPointView() argument109 cancellationListener.onProducerFutureCancelled(true); in newEntryPointView()
184 Producer<T> producer, CancellationListener cancellationListener) {188 return ((CancellableProducer<T>) producer).newEntryPointView(cancellationListener);231 public Producer<T> newEntryPointView(CancellationListener cancellationListener) {
42 Producer<T> newEntryPointView(CancellationListener cancellationListener); in newEntryPointView() argument
74 private Context.CancellationListener cancellationListener = new Context.CancellationListener() { field in ContextTest137 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 …]
460 public void addListener(final CancellationListener cancellationListener, in addListener() argument462 checkNotNull(cancellationListener, "cancellationListener"); in addListener()466 new ExecutableListener(executor, cancellationListener); in addListener()490 public void removeListener(CancellationListener cancellationListener) { in removeListener() argument497 if (listeners.get(i).listener == cancellationListener) { in removeListener()
60 public Producer<T> newEntryPointView(CancellationListener cancellationListener) { in newEntryPointView() argument
82 private final CancellationListener cancellationListener = new ContextCancellationListener(); field in ClientCallImpl279 context.addListener(cancellationListener, directExecutor()); in start()318 context.removeListener(cancellationListener); in removeContextListenerAndCancelDeadlineFuture()
META-INF/ META-INF/MANIFEST.MF build-data.properties META-INF ...