| /external/libchrome/base/android/junit/src/org/chromium/base/ |
| D | PromiseTest.java | 42 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 …]
|
| /external/cronet/base/android/junit/src/org/chromium/base/ |
| D | PromiseTest.java | 46 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 …]
|
| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | WriteQueue.java | 84 ChannelPromise promise = channel.newPromise(); in enqueue() local
165 public final void promise(ChannelPromise promise) { in promise() argument
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() argument
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
|
| D | SendGrpcFrameCommand.java | 35 private ChannelPromise promise; field in SendGrpcFrameCommand
119 public ChannelPromise promise() { in promise() method in SendGrpcFrameCommand
124 public void promise(ChannelPromise promise) { in promise() method in SendGrpcFrameCommand
|
| D | Http2ControlFrameLimitEncoder.java | 62 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()
|
| D | NettyClientHandler.java | 330 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 …]
|
| D | WriteBufferingAndExceptionHandler.java | 122 public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) { in write()
147 ChannelPromise promise) throws Exception { in connect()
250 final ChannelPromise promise; field in WriteBufferingAndExceptionHandler.ChannelWrite
252 ChannelWrite(Object msg, ChannelPromise promise) { in ChannelWrite()
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/test/java/software/amazon/awssdk/http/nio/netty/internal/ |
| D | ProxyTunnelInitHandlerTest.java | 106 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 …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/test/ |
| D | PromiseTest.kt | 13 val promise = Promise<String> { resolve, _ -> in <lambda>() constant
23 val promise = Promise<String> { _, reject -> in <lambda>() constant
44 val promise = deferred.asPromise() in <lambda>() constant
54 val promise = deferred.asPromise() in <lambda>() constant
72 val promise = deferred.asPromise() in <lambda>() constant
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/utils/ |
| D | DelegatingChannelHandlerContext.java | 145 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()
|
| D | OrderedWriteChannelHandlerContext.java | 46 public ChannelFuture write(Object msg, ChannelPromise promise) { in write()
59 public ChannelFuture writeAndFlush(Object msg, ChannelPromise promise) { in writeAndFlush()
67 ChannelPromise promise = newPromise(); in doInOrder() local
|
| D | BetterFixedChannelPool.java | 141 public Future<Channel> acquire(final Promise<Channel> promise) { in acquire()
171 private void acquire0(final Promise<Channel> promise) { in acquire0()
214 public Future<Void> release(final Channel channel, final Promise<Void> promise) { in release()
285 final Promise<Channel> promise; field in BetterFixedChannelPool.AcquireTask
289 public AcquireTask(Promise<Channel> promise) { in AcquireTask()
|
| /external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/ |
| D | TsiFrameHandler.java | 68 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()
|
| /external/grpc-grpc/test/core/transport/ |
| D | promise_endpoint_test.cc | 144 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 …]
|
| /external/federated-compute/fcp/base/ |
| D | future_test.cc | 74 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()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/ |
| D | Promise.kt | 25 public fun <T> CoroutineScope.promise( in <lambda>() method
36 val promise = Promise<T> { resolve, reject -> in <lambda>() constant
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/http2/ |
| D | Http2MultiplexedChannelPool.java | 125 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()
|
| D | HttpOrHttp2ChannelPool.java | 75 public Future<Channel> acquire(Promise<Channel> promise) { in acquire()
80 private void acquire0(Promise<Channel> promise) { in acquire0()
196 public Future<Void> release(Channel channel, Promise<Void> promise) { in release()
203 private void release0(Channel channel, Promise<Void> promise) { in release0()
|
| D | HttpToHttp2OutboundAdapter.java | 56 public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) { in write()
120 private final ChannelPromise promise; field in HttpToHttp2OutboundAdapter.SimpleChannelPromiseAggregator
126 SimpleChannelPromiseAggregator(ChannelPromise promise, Channel c, EventExecutor e) { in SimpleChannelPromiseAggregator()
|
| /external/cronet/base/android/java/src/org/chromium/base/ |
| D | Promise.java | 146 final Promise<RT> promise = new Promise<>(); in then() local
176 final Promise<RT> promise = new Promise<>(); in then() local
267 Promise<T> promise = new Promise<>(); in fulfilled() local
274 Promise<T> promise = new Promise<>(); in rejected() local
|
| /external/grpc-grpc/src/core/lib/promise/ |
| D | race.h | 35 explicit Race(Promise promise, Promises... promises) in Race()
60 explicit Race(Promise promise) : promise_(std::move(promise)) {} in Race()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/promise/ |
| D | race.h | 36 explicit Race(Promise promise, Promises... promises) in Race()
61 explicit Race(Promise promise) : promise_(std::move(promise)) {} in Race()
|
| D | if.h | 40 auto promise = if_true->Make(); in ChooseIf() local
43 auto promise = if_false->Make(); in ChooseIf() local
55 auto promise = if_true->Make(); in ChooseIf() local
58 auto promise = if_false->Make(); in ChooseIf() local
|
| /external/sdv/vsomeip/third_party/boost/thread/test/ |
| D | test_11818.cpp | 20 boost::promise<int> promise; in main() local
42 boost::promise<int> promise; in main() local
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/ |
| D | HonorCloseOnReleaseChannelPool.java | 49 public Future<Channel> acquire(Promise<Channel> promise) { in acquire()
59 public Future<Void> release(Channel channel, Promise<Void> promise) { in release()
|