Home
last modified time | relevance | path

Searched refs:AsyncFunction (Results 1 – 8 of 8) sorted by relevance

/external/guava/guava/src/com/google/common/util/concurrent/
DFutures.java564 AsyncFunction<? super I, ? extends O> function) { in transform()
611 AsyncFunction<? super I, ? extends O> function, in transform()
756 private static <I, O> AsyncFunction<I, O> asAsyncFunction(
758 return new AsyncFunction<I, O>() {
854 private AsyncFunction<? super I, ? extends O> function;
859 AsyncFunction<? super I, ? extends O> function,
973 return Futures.transform((ListenableFuture) nested, (AsyncFunction) DEREFERENCER);
979 private static final AsyncFunction<ListenableFuture<Object>, Object> DEREFERENCER =
980 new AsyncFunction<ListenableFuture<Object>, Object>() {
DAsyncFunction.java28 public interface AsyncFunction<I, O> { interface
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DFuturesTest.java233 AsyncFunction<Foo, Bar> function = new AsyncFunction<Foo, Bar>() { in testTransform_cancelPropagatesToInput()
245 AsyncFunction<Foo, Bar> function = new AsyncFunction<Foo, Bar>() { in testTransform_interruptPropagatesToInput()
258 AsyncFunction<Foo, Bar> function = new AsyncFunction<Foo, Bar>() { in testTransform_cancelPropagatesToAsyncOutput()
272 AsyncFunction<Foo, Bar> function = new AsyncFunction<Foo, Bar>() { in testTransform_interruptPropagatesToAsyncOutput()
657 private static <I, O> AsyncFunction<I, O> constantAsyncFunction(
659 return new AsyncFunction<I, O>() {
670 AsyncFunction<Foo, BarChild> function =
671 new AsyncFunction<Foo, BarChild>() {
684 AsyncFunction<String, Integer> function = constantAsyncFunction(Futures.immediateFuture(1));
695 AsyncFunction<String, Integer> function = new AsyncFunction<String, Integer>() {
[all …]
DFuturesTransformAsyncFunctionTest.java57 private class ChainingFunction implements AsyncFunction<Integer, String> {
/external/caliper/caliper/src/main/java/com/google/caliper/runner/
DExperimentingCaliperRun.java32 import com.google.common.util.concurrent.AsyncFunction;
225 new AsyncFunction<Object, TrialResult>() { in scheduleTrials()
/external/guava/guava-tests/benchmark/com/google/common/util/concurrent/
DFuturesCombineBenchmark.java44 return Futures.transform(trigger, new AsyncFunction<Object, V>() { in combine()
/external/dagger2/compiler/src/main/java/dagger/internal/codegen/
DProducerFactoryGenerator.java28 import com.google.common.util.concurrent.AsyncFunction;
201 ClassName.fromClass(AsyncFunction.class), in write()
/external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/shadows/
DShadowInstrumentation.java35 import com.google.common.util.concurrent.AsyncFunction;
336 new AsyncFunction<BroadcastResultHolder, BroadcastResultHolder>() { in postIntent()