Home
last modified time | relevance | path

Searched defs:promise (Results 1 – 25 of 246) sorted by relevance

12345678910

/aosp_15_r20/external/libchrome/base/android/junit/src/org/chromium/base/
H A DPromiseTest.java42 Promise<Integer> promise = new Promise<Integer>(); in callback() local
56 Promise<Integer> promise = new Promise<Integer>(); in multipleCallbacks() local
77 Promise<Integer> promise = Promise.fulfilled(new Integer(0)); in callbackOnFulfilled() local
88 Promise<Integer> promise = new Promise<Integer>(); in promiseChaining() local
116 Promise<Integer> promise = new Promise<Integer>(); in promiseChainingAsyncFunctions() local
147 Promise<Integer> promise = new Promise<Integer>(); in rejectPromiseNoCallbacks() local
162 Promise<Integer> promise = new Promise<Integer>(); in rejectPromiseNoHandler() local
178 Promise<Integer> promise = new Promise<Integer>(); in rejectPromiseHandled() local
195 Promise<Integer> promise = new Promise<Integer>(); in rejectionInformation() local
213 Promise<Integer> promise = new Promise<Integer>(); in rejectionChaining() local
[all …]
/aosp_15_r20/external/cronet/base/android/junit/src/org/chromium/base/
H A DPromiseTest.java46 Promise<Integer> promise = new Promise<>(); in callback() local
60 Promise<Integer> promise = new Promise<>(); in multipleCallbacks() local
79 Promise<Integer> promise = Promise.fulfilled(0); in callbackOnFulfilled() local
90 Promise<Integer> promise = new Promise<>(); in promiseChaining() local
108 Promise<Integer> promise = new Promise<>(); in promiseChainingAsyncFunctions() local
133 Promise<Integer> promise = new Promise<>(); in rejectPromiseNoCallbacks() local
148 Promise<Integer> promise = new Promise<>(); in rejectPromiseNoHandler() local
164 Promise<Integer> promise = new Promise<>(); in rejectPromiseHandled() local
180 Promise<Integer> promise = new Promise<>(); in rejectionInformation() local
198 Promise<Integer> promise = new Promise<>(); in rejectionChaining() local
[all …]
/aosp_15_r20/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/
H A DWriteQueue.java84 ChannelPromise promise = channel.newPromise(); in enqueue() local
165 public final void promise(ChannelPromise promise) { in promise() method in WriteQueue.RunnableCommand
170 public final ChannelPromise promise() { in promise() method in WriteQueue.RunnableCommand
187 private ChannelPromise promise; field in WriteQueue.AbstractQueuedCommand
195 public final void promise(ChannelPromise promise) { in promise() method in WriteQueue.AbstractQueuedCommand
200 public final ChannelPromise promise() { in promise() method in WriteQueue.AbstractQueuedCommand
222 ChannelPromise promise(); in promise() method
227 void promise(ChannelPromise promise); in promise() method
H A DNettyClientHandler.java330 public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) in write()
333 createStream((CreateStreamCommand) msg, promise); in write() local
421 public void close(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception { in close()
538 private void createStream(CreateStreamCommand command, ChannelPromise promise) in createStream()
610 final ChannelPromise promise) { in createStreamTraced()
670 ChannelPromise promise) { in cancelStream()
691 ChannelPromise promise) { in sendGrpcFrame()
702 ChannelPromise promise) { in sendPingFrame()
714 ChannelPromise promise) { in sendPingFrameTraced()
768 ChannelPromise promise) throws Exception { in gracefulClose()
[all …]
H A DNettyServerHandler.java642 public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) in write()
664 public void close(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception { in close()
680 private void closeStreamWhenDone(ChannelPromise promise, int streamId) throws Http2Exception { in closeStreamWhenDone()
694 ChannelPromise promise) throws Http2Exception { in sendGrpcFrame()
710 ChannelPromise promise) throws Http2Exception { in sendResponseHeaders()
730 ChannelPromise promise) { in cancelStream()
742 ChannelPromise promise) throws Exception { in gracefulClose()
757 ChannelPromise promise) throws Exception { in forcefulClose()
1049 int padding, boolean endStream, ChannelPromise promise) { in writeData()
1056 int padding, boolean endStream, ChannelPromise promise) { in writeHeaders()
[all …]
H A DSendGrpcFrameCommand.java35 private ChannelPromise promise; field in SendGrpcFrameCommand
119 public ChannelPromise promise() { in promise() method in SendGrpcFrameCommand
124 public void promise(ChannelPromise promise) { in promise() argument
H A DHttp2ControlFrameLimitEncoder.java62 public ChannelFuture writeSettingsAck(ChannelHandlerContext ctx, ChannelPromise promise) { in writeSettingsAck()
71 …hannelFuture writePing(ChannelHandlerContext ctx, boolean ack, long data, ChannelPromise promise) { in writePing()
85 ChannelHandlerContext ctx, int streamId, long errorCode, ChannelPromise promise) { in writeRstStream()
93 … ChannelPromise handleOutstandingControlFrames(ChannelHandlerContext ctx, ChannelPromise promise) { in handleOutstandingControlFrames()
/aosp_15_r20/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/
H A DProxyTunnelInitHandlerTest.java106 Promise<Channel> promise = GROUP.next().newPromise(); in successfulProxyResponse_completesFuture() local
117 Promise<Channel> promise = GROUP.next().newPromise(); in successfulProxyResponse_removesSelfAndCodec() local
129 Promise<Channel> promise = GROUP.next().newPromise(); in successfulProxyResponse_doesNotRemoveSslHandler() local
139 Promise<Channel> promise = GROUP.next().newPromise(); in unexpectedMessage_failsPromise() local
148 Promise<Channel> promise = GROUP.next().newPromise(); in unsuccessfulResponse_failsPromise() local
163 Promise<Channel> promise = GROUP.next().newPromise(); in requestWriteFails_failsPromise() local
172 Promise<Channel> promise = GROUP.next().newPromise(); in channelInactive_shouldFailPromise() local
183 Promise<Channel> promise = GROUP.next().newPromise(); in unexpectedExceptionThrown_shouldFailPromise() local
196 Promise<Channel> promise = GROUP.next().newPromise(); in handlerRemoved_removesCodec() local
206 Promise<Channel> promise = GROUP.next().newPromise(); in handledAdded_writesRequest_withoutAuth() local
[all …]
/aosp_15_r20/external/grpc-grpc/test/core/transport/
H A Dpromise_endpoint_test.cc144 auto promise = promise_endpoint_->Read(kBuffer.size()); in TEST_F() local
163 auto promise = promise_endpoint_->Read(kDummyRequestSize); in TEST_F() local
198 auto promise = promise_endpoint_->Read(4u); in TEST_F() local
205 auto promise = promise_endpoint_->Read(4u); in TEST_F() local
233 auto promise = promise_endpoint_->Read(kBuffer.size()); in TEST_F() local
256 auto promise = promise_endpoint_->Read(kDummyRequestSize); in TEST_F() local
281 auto promise = promise_endpoint_->ReadSlice(kBuffer.size()); in TEST_F() local
300 auto promise = promise_endpoint_->ReadSlice(kDummyRequestSize); in TEST_F() local
335 auto promise = promise_endpoint_->ReadSlice(4u); in TEST_F() local
342 auto promise = promise_endpoint_->ReadSlice(4u); in TEST_F() local
[all …]
/aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/js/test/
H A DPromiseTest.kt10 val promise = Promise<String> { resolve, _ -> in <lambda>() constant
20 val promise = Promise<String> { _, reject -> in <lambda>() constant
41 val promise = deferred.asPromise() in <lambda>() constant
51 val promise = deferred.asPromise() in <lambda>() constant
69 val promise = deferred.asPromise() in <lambda>() constant
/aosp_15_r20/external/kotlinx.coroutines/kotlinx-coroutines-core/wasmJs/test/
H A DPromiseTest.kt10 val promise = Promise<JsReference<String>> { resolve, _ -> in <lambda>() constant
20 val promise = Promise<JsAny?> { _, reject -> in <lambda>() constant
41 val promise = deferred.asPromise() in <lambda>() constant
51 val promise = deferred.asPromise() in <lambda>() constant
69 val promise = deferred.asPromise() in <lambda>() constant
/aosp_15_r20/packages/modules/Bluetooth/system/gd/os/linux_generic/
Dalarm_timerfd_unittest.cc79 auto promise = std::make_unique<std::promise<void>>(); in TEST_P() local
86 auto promise = std::make_unique<std::promise<void>>(); in TEST_P() local
94 auto promise = std::promise<void>(); in TEST_P() local
97 [](std::shared_ptr<Alarm> alarm, std::promise<void> promise) { in TEST_P()
108 auto promise = std::make_unique<std::promise<void>>(); in TEST_P() local
116 auto promise = std::make_unique<std::promise<void>>(); in TEST_P() local
139 auto promise = std::make_unique<std::promise<void>>(); in TEST_P() local
143 [](std::shared_ptr<Alarm> alarm2, std::unique_ptr<std::promise<void>> promise) { in TEST_P()
Dalarm_unittest.cc67 std::promise<void> promise; in TEST_P() local
84 std::promise<void> promise; in TEST_P() local
87 [](std::shared_ptr<Alarm> alarm, std::promise<void> promise) { in TEST_P()
101 std::promise<void> promise; in TEST_P() local
131 auto promise = std::make_unique<std::promise<void>>(); in TEST_P() local
138 std::unique_ptr<std::promise<void>> promise2) { in TEST_P()
Drepeating_alarm_unittest.cc51 std::promise<void> promise; in VerifyMultipleDelayedTasks() local
66 int scheduled_tasks, std::promise<void>* promise, in verify_delayed_tasks()
90 std::promise<void> promise; in TEST_F() local
108 std::promise<void> promise; in TEST_F() local
111 [](RepeatingAlarm* alarm, std::promise<void>* promise) { in TEST_F()
123 std::promise<void> promise; in TEST_F() local
/aosp_15_r20/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/utils/
H A DDelegatingChannelHandlerContext.java145 public ChannelFuture bind(SocketAddress localAddress, ChannelPromise promise) { in bind()
150 public ChannelFuture connect(SocketAddress remoteAddress, ChannelPromise promise) { in connect()
155 …elFuture connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise) { in connect()
160 public ChannelFuture disconnect(ChannelPromise promise) { in disconnect()
165 public ChannelFuture close(ChannelPromise promise) { in close()
170 public ChannelFuture deregister(ChannelPromise promise) { in deregister()
185 public ChannelFuture write(Object msg, ChannelPromise promise) { in write()
195 public ChannelFuture writeAndFlush(Object msg, ChannelPromise promise) { in writeAndFlush()
/aosp_15_r20/hardware/interfaces/bluetooth/hci/test/
H A Dh4_protocol_unittest.cc122 void ExpectInboundAclData(char* payload, std::promise<void>* promise) { in ExpectInboundAclData()
137 void WaitForTimeout(std::promise<void>* promise) { in WaitForTimeout()
149 void ExpectInboundScoData(char* payload, std::promise<void>* promise) { in ExpectInboundScoData()
167 void ExpectInboundEvent(char* payload, std::promise<void>* promise) { in ExpectInboundEvent()
186 void ExpectInboundIsoData(char* payload, std::promise<void>* promise) { in ExpectInboundIsoData()
411 std::promise<void> promise; in WriteAndExpectInboundAclData() local
418 std::promise<void> promise; in WriteAndExpectInboundScoData() local
425 std::promise<void> promise; in WriteAndExpectInboundEvent() local
432 std::promise<void> promise; in WriteAndExpectInboundIsoData() local
487 std::promise<void> promise; in TEST_F() local
/aosp_15_r20/packages/modules/Bluetooth/system/gd/common/
Dbidi_queue_unittest.cc68 std::promise<void>* promise = new std::promise<void>(); in Send() local
75 std::promise<TB*>* promise = new std::promise<TB*>(); in Receive() local
82 void handle_send(TA* value, std::promise<void>* promise) { in handle_send()
88 std::unique_ptr<TA> handle_register_enqueue(TA* value, std::promise<void>* promise) { in handle_register_enqueue()
94 void handle_receive(std::promise<TB*>* promise) { in handle_receive()
99 void handle_register_dequeue(std::promise<TB*>* promise) { in handle_register_dequeue()
/aosp_15_r20/external/federated-compute/fcp/base/
H A Dfuture_test.cc74 void SetV(Promise<UV> promise) { std::move(promise).Set(UV(Unit{})); } in SetV()
112 auto promise_fn = [&](Promise<UV> promise) { in TEST()
135 auto promise_fn = [&](Promise<UV> promise) { in TEST()
149 auto promise_fn = [](Promise<UV> promise) { in TEST()
162 auto promise_fn = [](Promise<UV> promise) { in TEST()
175 auto promise_fn = [](Promise<UV> promise) { in TEST()
188 auto promise_fn = [](Promise<UV> promise) { in TEST()
/aosp_15_r20/external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/
H A DTsiFrameHandler.java68 public void write(ChannelHandlerContext ctx, Object message, ChannelPromise promise) { in write()
90 public void disconnect(ChannelHandlerContext ctx, ChannelPromise promise) { in disconnect()
96 public void close(ChannelHandlerContext ctx, ChannelPromise promise) { in close()
156 public void bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) { in bind()
166 ChannelPromise promise) { in connect()
172 public void deregister(ChannelHandlerContext ctx, ChannelPromise promise) { in deregister()
/aosp_15_r20/external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/http2/
H A DHttp2MultiplexedChannelPool.java125 public Future<Channel> acquire(Promise<Channel> promise) { in acquire()
141 private void acquireStreamOnNewConnection(Promise<Channel> promise) { in acquireStreamOnNewConnection()
164 …private void acquireStreamOnFreshConnection(Promise<Channel> promise, Channel parentChannel, Proto… in acquireStreamOnFreshConnection()
204 Promise<Channel> promise) { in cacheConnectionForFutureStreams()
250 …private Void failAndCloseParent(Promise<Channel> promise, Channel parentChannel, Throwable excepti… in failAndCloseParent()
264 …reStreamOnInitializedConnection(MultiplexedChannelRecord channelRecord, Promise<Channel> promise) { in acquireStreamOnInitializedConnection()
298 public Future<Void> release(Channel childChannel, Promise<Void> promise) { in release()
/aosp_15_r20/packages/modules/Bluetooth/system/btif/src/
Dstack_manager.cc150 std::promise<void> promise; in init_stack() local
171 std::promise<void> promise; in clean_up_stack() local
186 static void start_up_rust_module_async(std::promise<void> promise) { in start_up_rust_module_async()
258 static void event_init_stack(std::promise<void> promise, in event_init_stack()
395 static void event_start_up_rust_module(std::promise<void> promise) { in event_start_up_rust_module()
416 static void event_clean_up_stack(std::promise<void> promise, ProfileStopCallback stopProfiles) { in event_clean_up_stack()
/aosp_15_r20/packages/modules/Bluetooth/system/test/headless/
Dbt_stack_info.cc31 std::promise<pid_t> promise; in BtStackInfo() local
34 [](std::promise<pid_t> promise) { promise.set_value(getpid()); }, std::move(promise))); in BtStackInfo()
39 std::promise<pid_t> promise; in BtStackInfo() local
42 [](std::promise<pid_t> promise) { promise.set_value(getpid()); }, std::move(promise))); in BtStackInfo()
/aosp_15_r20/packages/modules/Bluetooth/system/gd/
Dstack_manager.cc44 std::promise<void> promise; in StartUp() local
63 std::promise<void> promise) { in handle_start_up()
71 std::promise<void> promise; in ShutDown() local
91 void StackManager::handle_shut_down(std::promise<void> promise) { in handle_shut_down()
/aosp_15_r20/packages/modules/Bluetooth/system/gd/hci/
Dacl_manager_unittest.cc167 std::promise<void> promise; in sync_client_handler() local
211 std::promise<void> promise; in SendAclData() local
216 [](decltype(queue_end) queue_end, uint16_t handle, std::promise<void> promise) { in SendAclData()
240 std::promise<void> promise; in TearDown() local
246 std::promise<void> promise; in TearDown() local
419 std::promise<void> promise; in sync_client_handler() local
471 auto promise = std::promise<void>(); in TEST_F() local
Dremote_name_request_test.cc98 common::ContextualOnceCallback<void(T...)> promiseCallback(std::promise<void> promise) { in promiseCallback()
100 [](std::promise<void> promise, T... /* args */) { promise.set_value(); }, in promiseCallback()
106 std::promise<std::tuple<T...>> promise) { in capturingPromiseCallback()
108 T... args) { promise.set_value(std::make_tuple(args...)); }, in capturingPromiseCallback()
113 common::ContextualOnceCallback<void(T)> capturingPromiseCallback(std::promise<T> promise) { in capturingPromiseCallback()
114 return client_handler_->BindOnce([](std::promise<T> promise, T arg) { promise.set_value(arg); }, in capturingPromiseCallback()

12345678910