| /external/libchrome/base/android/junit/src/org/chromium/base/ |
| D | PromiseTest.java | 42 Promise<Integer> promise = new Promise<Integer>(); in callback() local
43 promise.then(PromiseTest.<Integer>setValue(value, 1)); in callback()
47 promise.fulfill(new Integer(1)); in callback()
56 Promise<Integer> promise = new Promise<Integer>(); in multipleCallbacks() local
63 promise.then(callback); in multipleCallbacks()
64 promise.then(callback); in multipleCallbacks()
68 promise.fulfill(new Integer(0)); in multipleCallbacks()
77 Promise<Integer> promise = Promise.fulfilled(new Integer(0)); in callbackOnFulfilled() local
80 promise.then(PromiseTest.<Integer>setValue(value, 1)); in callbackOnFulfilled()
88 Promise<Integer> promise = new Promise<Integer>(); in promiseChaining() local
[all …]
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | WriteQueue.java | 79 Preconditions.checkArgument(command.promise() == null, "promise must not be set on command"); in enqueue()
81 ChannelPromise promise = channel.newPromise(); in enqueue() local
82 command.promise(promise); in enqueue()
87 return promise; in enqueue()
143 public final void promise(ChannelPromise promise) { in promise() argument
148 public final ChannelPromise promise() { in promise() method in WriteQueue.RunnableCommand
160 private ChannelPromise promise; field in WriteQueue.AbstractQueuedCommand
163 public final void promise(ChannelPromise promise) { in promise() method in WriteQueue.AbstractQueuedCommand
164 this.promise = promise; in promise()
168 public final ChannelPromise promise() { in promise() method in WriteQueue.AbstractQueuedCommand
[all …]
|
| D | SendGrpcFrameCommand.java | 32 private ChannelPromise promise; field in SendGrpcFrameCommand
110 public ChannelPromise promise() { in promise() method in SendGrpcFrameCommand
111 return promise; in promise()
115 public void promise(ChannelPromise promise) { in promise() method in SendGrpcFrameCommand
116 this.promise = promise; in promise()
121 channel.write(this, promise); in run()
|
| D | NettyClientHandler.java | 297 public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) in write() argument
300 createStream((CreateStreamCommand) msg, promise); in write() local
302 sendGrpcFrame(ctx, (SendGrpcFrameCommand) msg, promise); in write()
304 cancelStream(ctx, (CancelClientStreamCommand) msg, promise); in write()
306 sendPingFrame(ctx, (SendPingCommand) msg, promise); in write()
308 gracefulClose(ctx, (GracefulCloseCommand) msg, promise); in write()
310 forcefulClose(ctx, (ForcefulCloseCommand) msg, promise); in write()
312 ctx.write(Unpooled.EMPTY_BUFFER, promise); in write()
383 public void close(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception { in close() argument
389 super.close(ctx, promise); in close()
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/test/ |
| D | PromiseTest.kt | 12 fun testPromiseResolvedAsDeferred() = GlobalScope.promise { in <lambda>()
13 val promise = Promise<String> { resolve, _ -> in <lambda>() constant
16 val deferred = promise.asDeferred() in <lambda>()
21 fun testPromiseRejectedAsDeferred() = GlobalScope.promise { in <lambda>()
23 val promise = Promise<String> { _, reject -> in <lambda>() constant
26 val deferred = promise.asDeferred() in <lambda>()
39 fun testCompletedDeferredAsPromise() = GlobalScope.promise { in <lambda>()
44 val promise = deferred.asPromise() in <lambda>() constant
45 assertEquals("OK", promise.await()) in <lambda>()
49 fun testWaitForDeferredAsPromise() = GlobalScope.promise { in <lambda>()
[all …]
|
| /external/libcxx/test/std/thread/futures/futures.promise/ |
| D | copy_ctor.fail.cpp | 26 std::promise<int> p0; in main()
27 … std::promise<int> p(p0); // expected-error {{call to deleted constructor of 'std::promise<int>'}} in main()
30 std::promise<int &> p0; in main()
31 …std::promise<int &> p(p0); // expected-error {{call to deleted constructor of 'std::promise<int &>… in main()
34 std::promise<void> p0; in main()
35 …std::promise<void> p(p0); // expected-error {{call to deleted constructor of 'std::promise<void>'}} in main()
39 std::promise<int> p0; in main()
40 …std::promise<int> p(p0); // expected-error {{calling a private constructor of class 'std::__1::pro… in main()
43 std::promise<int &> p0; in main()
44 …std::promise<int &> p(p0); // expected-error {{calling a private constructor of class 'std::__1::p… in main()
[all …]
|
| D | alloc_ctor.pass.cpp | 30 std::promise<int> p(std::allocator_arg, test_allocator<int>(42)); in main()
38 std::promise<int&> p(std::allocator_arg, test_allocator<int>(42)); in main()
46 std::promise<void> p(std::allocator_arg, test_allocator<void>(42)); in main()
55 std::promise<int> p(std::allocator_arg, bare_allocator<void>()); in main()
60 std::promise<int&> p(std::allocator_arg, bare_allocator<void>()); in main()
65 std::promise<void> p(std::allocator_arg, bare_allocator<void>()); in main()
71 std::promise<int> p(std::allocator_arg, min_allocator<void>()); in main()
76 std::promise<int&> p(std::allocator_arg, min_allocator<void>()); in main()
81 std::promise<void> p(std::allocator_arg, min_allocator<void>()); in main()
|
| D | copy_assign.fail.cpp | 26 std::promise<int> p0, p; in main()
30 std::promise<int&> p0, p; in main()
34 std::promise<void> p0, p; in main()
39 std::promise<int> p0, p; in main()
43 std::promise<int&> p0, p; in main()
47 std::promise<void> p0, p; in main()
|
| D | swap.pass.cpp | 30 std::promise<int> p0(std::allocator_arg, test_allocator<int>()); in main()
31 std::promise<int> p(std::allocator_arg, test_allocator<int>()); in main()
44 std::promise<int> p0(std::allocator_arg, test_allocator<int>()); in main()
45 std::promise<int> p(std::allocator_arg, test_allocator<int>()); in main()
58 std::promise<int> p0(std::allocator_arg, test_allocator<int>()); in main()
59 std::promise<int> p; in main()
72 std::promise<int> p0(std::allocator_arg, test_allocator<int>()); in main()
73 std::promise<int> p; in main()
|
| /external/libchrome/base/android/java/src/org/chromium/base/ |
| D | Promise.java | 153 final Promise<R> promise = new Promise<>(); in then() local
160 promise.fulfill(function.apply(result)); in then()
163 promise.reject(e); in then()
168 exceptInner(promise::reject); in then()
170 return promise; in then()
182 final Promise<R> promise = new Promise<>(); in then() local
191 function.apply(result).then(promise::fulfill, promise::reject); in then()
194 promise.reject(e); in then()
199 exceptInner(promise::reject); in then()
201 return promise; in then()
[all …]
|
| /external/libcxx/test/std/thread/futures/futures.unique_future/ |
| D | get.pass.cpp | 26 void func1(std::promise<int> p) in func1()
32 void func2(std::promise<int> p) in func2()
40 void func3(std::promise<int&> p) in func3()
47 void func4(std::promise<int&> p) in func4()
53 void func5(std::promise<void> p) in func5()
59 void func6(std::promise<void> p) in func6()
70 std::promise<T> p; in main()
79 std::promise<T> p; in main()
99 std::promise<T> p; in main()
108 std::promise<T> p; in main()
[all …]
|
| /external/llvm-project/libcxx/test/std/thread/futures/futures.shared_future/ |
| D | get.pass.cpp | 26 void func1(std::promise<int> p) in func1()
32 void func2(std::promise<int> p) in func2()
40 void func3(std::promise<int&> p) in func3()
47 void func4(std::promise<int&> p) in func4()
53 void func5(std::promise<void> p) in func5()
59 void func6(std::promise<void> p) in func6()
70 std::promise<T> p; in main()
79 std::promise<T> p; in main()
99 std::promise<T> p; in main()
108 std::promise<T> p; in main()
[all …]
|
| /external/libcxx/test/std/thread/futures/futures.shared_future/ |
| D | get.pass.cpp | 26 void func1(std::promise<int> p) in func1()
32 void func2(std::promise<int> p) in func2()
40 void func3(std::promise<int&> p) in func3()
47 void func4(std::promise<int&> p) in func4()
53 void func5(std::promise<void> p) in func5()
59 void func6(std::promise<void> p) in func6()
70 std::promise<T> p; in main()
79 std::promise<T> p; in main()
99 std::promise<T> p; in main()
108 std::promise<T> p; in main()
[all …]
|
| /external/llvm-project/libcxx/test/std/thread/futures/futures.unique_future/ |
| D | get.pass.cpp | 26 void func1(std::promise<int> p) in func1()
32 void func2(std::promise<int> p) in func2()
40 void func3(std::promise<int&> p) in func3()
47 void func4(std::promise<int&> p) in func4()
53 void func5(std::promise<void> p) in func5()
59 void func6(std::promise<void> p) in func6()
70 std::promise<T> p; in main()
79 std::promise<T> p; in main()
99 std::promise<T> p; in main()
108 std::promise<T> p; in main()
[all …]
|
| /external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/ |
| D | TsiFrameHandler.java | 82 public void write(ChannelHandlerContext ctx, Object message, ChannelPromise promise) in write() argument
89 Future<?> possiblyIgnoredError = promise.setSuccess(); in write()
94 pendingUnprotectedWrites.add(msg, promise); in write()
112 public void bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) { in bind() argument
113 ctx.bind(localAddress, promise); in bind()
121 ChannelPromise promise) { in connect() argument
122 ctx.connect(remoteAddress, localAddress, promise); in connect()
126 public void disconnect(ChannelHandlerContext ctx, ChannelPromise promise) { in disconnect() argument
127 ctx.disconnect(promise); in disconnect()
131 public void close(ChannelHandlerContext ctx, ChannelPromise promise) { in close() argument
[all …]
|
| /external/llvm-project/libcxx/test/std/thread/futures/futures.promise/ |
| D | copy_ctor.verify.cpp | 24 std::promise<int> p0; in main()
25 … std::promise<int> p(p0); // expected-error {{call to deleted constructor of 'std::promise<int>'}} in main()
28 std::promise<int &> p0; in main()
29 …std::promise<int &> p(p0); // expected-error {{call to deleted constructor of 'std::promise<int &>… in main()
32 std::promise<void> p0; in main()
33 …std::promise<void> p(p0); // expected-error {{call to deleted constructor of 'std::promise<void>'}} in main()
|
| D | alloc_ctor.pass.cpp | 30 std::promise<int> p(std::allocator_arg, test_allocator<int>(42)); in main()
38 std::promise<int&> p(std::allocator_arg, test_allocator<int>(42)); in main()
46 std::promise<void> p(std::allocator_arg, test_allocator<void>(42)); in main()
55 std::promise<int> p(std::allocator_arg, bare_allocator<void>()); in main()
60 std::promise<int&> p(std::allocator_arg, bare_allocator<void>()); in main()
65 std::promise<void> p(std::allocator_arg, bare_allocator<void>()); in main()
71 std::promise<int> p(std::allocator_arg, min_allocator<void>()); in main()
76 std::promise<int&> p(std::allocator_arg, min_allocator<void>()); in main()
81 std::promise<void> p(std::allocator_arg, min_allocator<void>()); in main()
|
| D | swap.pass.cpp | 30 std::promise<int> p0(std::allocator_arg, test_allocator<int>()); in main()
31 std::promise<int> p(std::allocator_arg, test_allocator<int>()); in main()
44 std::promise<int> p0(std::allocator_arg, test_allocator<int>()); in main()
45 std::promise<int> p(std::allocator_arg, test_allocator<int>()); in main()
58 std::promise<int> p0(std::allocator_arg, test_allocator<int>()); in main()
59 std::promise<int> p; in main()
72 std::promise<int> p0(std::allocator_arg, test_allocator<int>()); in main()
73 std::promise<int> p; in main()
|
| /external/libcxx/include/ |
| D | future | 59 class promise
62 promise();
64 promise(allocator_arg_t, const Allocator& a);
65 promise(promise&& rhs) noexcept;
66 promise(const promise& rhs) = delete;
67 ~promise();
70 promise& operator=(promise&& rhs) noexcept;
71 promise& operator=(const promise& rhs) = delete;
72 void swap(promise& other) noexcept;
89 class promise<R&>
[all …]
|
| /external/llvm-project/libcxx/include/ |
| D | future | 58 class promise
61 promise();
63 promise(allocator_arg_t, const Allocator& a);
64 promise(promise&& rhs) noexcept;
65 promise(const promise& rhs) = delete;
66 ~promise();
69 promise& operator=(promise&& rhs) noexcept;
70 promise& operator=(const promise& rhs) = delete;
71 void swap(promise& other) noexcept;
88 class promise<R&>
[all …]
|
| /external/libcxx/test/std/experimental/language.support/support.coroutines/coroutine.handle/coroutine.handle.prom/ |
| D | promise.pass.cpp | 51 assert(&h.promise() == this); in do_runtime_test()
52 assert(&h2.promise() == this); in do_runtime_test()
53 assert(&h3.promise() == this); in do_runtime_test()
69 ASSERT_SAME_TYPE(decltype(H.promise()), Promise&); in do_test()
70 LIBCPP_ASSERT_NOT_NOEXCEPT(H.promise()); in do_test()
74 ASSERT_SAME_TYPE(decltype(CH.promise()), Promise&); in do_test()
75 LIBCPP_ASSERT_NOT_NOEXCEPT(CH.promise()); in do_test()
|
| /external/llvm-project/libcxx/test/std/experimental/language.support/support.coroutines/coroutine.handle/coroutine.handle.prom/ |
| D | promise.pass.cpp | 50 assert(&h.promise() == this); in do_runtime_test()
51 assert(&h2.promise() == this); in do_runtime_test()
52 assert(&h3.promise() == this); in do_runtime_test()
68 ASSERT_SAME_TYPE(decltype(H.promise()), Promise&); in do_test()
69 LIBCPP_ASSERT_NOT_NOEXCEPT(H.promise()); in do_test()
73 ASSERT_SAME_TYPE(decltype(CH.promise()), Promise&); in do_test()
74 LIBCPP_ASSERT_NOT_NOEXCEPT(CH.promise()); in do_test()
|
| /external/llvm-project/llvm/test/Transforms/Coroutines/ |
| D | ex4.ll | 1 ; Fourth example from Doc/Coroutines.rst (coroutine promise)
7 %promise = alloca i32
8 %pv = bitcast i32* %promise to i8*
23 store i32 %n.val, i32* %promise
40 %promise.addr.raw = call i8* @llvm.coro.promise(i8* %hdl, i32 4, i1 false)
41 %promise.addr = bitcast i8* %promise.addr.raw to i32*
42 %val0 = load i32, i32* %promise.addr
45 %val1 = load i32, i32* %promise.addr
48 %val2 = load i32, i32* %promise.addr
58 declare i8* @llvm.coro.promise(i8*, i32, i1)
|
| /external/llvm-project/libcxx/src/ |
| D | future.cpp | 199 promise<void>::promise() in promise() function in promise
204 promise<void>::~promise() in ~promise()
219 promise<void>::get_future() in get_future()
227 promise<void>::set_value() in set_value()
235 promise<void>::set_exception(exception_ptr __p) in set_exception()
243 promise<void>::set_value_at_thread_exit() in set_value_at_thread_exit()
251 promise<void>::set_exception_at_thread_exit(exception_ptr __p) in set_exception_at_thread_exit()
|
| /external/libcxx/src/ |
| D | future.cpp | 200 promise<void>::promise() in promise() function in promise
205 promise<void>::~promise() in ~promise()
220 promise<void>::get_future() in get_future()
228 promise<void>::set_value() in set_value()
236 promise<void>::set_exception(exception_ptr __p) in set_exception()
244 promise<void>::set_value_at_thread_exit() in set_value_at_thread_exit()
252 promise<void>::set_exception_at_thread_exit(exception_ptr __p) in set_exception_at_thread_exit()
|