| /aosp_15_r20/external/pigweed/pw_rpc/ts/ |
| H A D | client_test.ts | 350 const onNext = jest.fn(); constant
380 const onNext = jest.fn(); constant
398 const onNext = jest.fn(); constant
427 const [_call, onNext, onCompleted, onError] = callsAndCallbacks[i]; constant
455 const onNext = jest.fn(); constant
531 const onNext = jest.fn(); constant
572 const onNext = jest.fn(); constant
610 const onNext = jest.fn(); constant
657 const onNext = jest.fn(); constant
699 const onNext = jest.fn(); constant
[all …]
|
| /aosp_15_r20/external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/test/ |
| H A D | PublishTest.kt | 21 override fun onNext(t: Int?) { expectUnreached() } in <lambda>() method
44 override fun onNext(t: Int) { in <lambda>() method
69 override fun onNext(t: Int) { expectUnreached() } in <lambda>() method
110 override fun onNext(t: Unit?) { in <lambda>() method
169 override fun onNext(t: String) { in <lambda>() method
206 override fun onNext(t: Int) { in <lambda>() method
|
| H A D | FlowAsPublisherTest.kt | 34 override fun onNext(t: Int) { in testErrorOnCancellationIsReported() method
64 override fun onNext(t: Int) { in testCancellationIsNotReported() method
|
| H A D | PublisherAsFlowTest.kt | 13 var onNext = 0 in <lambda>() variable
|
| /aosp_15_r20/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| H A D | PublishTest.kt | 25 override fun onNext(t: Int?) { expectUnreached() } in <lambda>() method
48 override fun onNext(t: Int) { in <lambda>() method
73 override fun onNext(t: Int) { expectUnreached() } in <lambda>() method
114 override fun onNext(t: Unit?) { in <lambda>() method
173 override fun onNext(t: String) { in <lambda>() method
210 override fun onNext(t: Int) { in <lambda>() method
|
| H A D | FlowAsPublisherTest.kt | 35 override fun onNext(t: Int) { in <lambda>() method
65 override fun onNext(t: Int) { in <lambda>() method
93 override fun onNext(t: Int) { in <lambda>() method
130 override fun onNext(t: Int) { in <lambda>() method
|
| H A D | IterableFlowTckTest.kt | 58 override fun onNext(aLong: Long) { in testStackOverflowTrampoline() method
95 override fun onNext(aLong: Long) { in testConcurrentRequest() method
|
| /aosp_15_r20/external/pigweed/pw_rpc/java/main/dev/pigweed/pw_rpc/ |
| H A D | FutureCall.java | 140 private final Consumer<ResponseT> onNext; field in FutureCall.StreamResponseFuture
144 Consumer<ResponseT> onNext) { in getFactory()
148 private StreamResponseFuture(Endpoint endpoint, PendingRpc rpc, Consumer<ResponseT> onNext) { in StreamResponseFuture()
|
| H A D | MethodClient.java | 103 MessageLite request, Consumer<? extends MessageLite> onNext) { in invokeServerStreamingFuture()
169 Consumer<ResponseT> onNext) { in invokeBidirectionalStreamingFuture()
|
| /aosp_15_r20/external/dagger2/javatests/dagger/grpc/functional/server/ |
| H A D | FriendlyBarista.java | 52 public void onNext(CoffeeRequest value) { in clientStreamingGetCoffee() method
85 public void onNext(CoffeeRequest value) { in bidiStreamingGetCoffee() method
|
| /aosp_15_r20/prebuilts/tools/common/m2/repository/io/reactivex/rxjava2/rxjava/2.2.9/ |
| HD | rxjava-2.2.9.jar | META-INF/
META-INF/MANIFEST.MF
io/
io/reactivex/
io/ ... |
| /aosp_15_r20/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| H A D | FlowAsFlowableTest.kt | 29 override fun onNext(t: Int) { in <lambda>() method
66 override fun onNext(t: Int) { in <lambda>() method
|
| H A D | ObservableAsFlowTest.kt | 18 var onNext = 0 in testCancellation() variable
|
| H A D | FlowAsObservableTest.kt | 155 override fun onNext(t: Int) { in <lambda>() method
188 override fun onNext(t: Int) { in <lambda>() method
|
| /aosp_15_r20/external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| H A D | FlowAsFlowableTest.kt | 29 override fun onNext(t: Int) { in <lambda>() method
66 override fun onNext(t: Int) { in <lambda>() method
|
| H A D | FlowAsObservableTest.kt | 155 override fun onNext(t: Int) { in <lambda>() method
188 override fun onNext(t: Int) { in <lambda>() method
|
| /aosp_15_r20/external/sdk-platform-java/gax-java/gax/src/main/java/com/google/api/gax/tracing/ |
| H A D | TracedClientStreamingCallable.java | 112 public void onNext(RequestT value) { in onNext() method in TracedClientStreamingCallable.TracedRequestObserver
154 public void onNext(RequestT value) { in onNext() method in TracedClientStreamingCallable.TracedResponseObserver
|
| /aosp_15_r20/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| H A D | TestServiceImpl.java | 185 public void onNext(StreamingInputCallRequest message) { in streamingInputCall() method
215 public void onNext(StreamingOutputCallRequest request) { in fullDuplexCall() method
|
| /aosp_15_r20/external/aws-sdk-java-v2/services/s3/src/main/java/software/amazon/awssdk/services/s3/internal/checksums/ |
| H A D | S3ChecksumValidatingPublisher.java | 80 public void onNext(ByteBuffer byteBuffer) { in onNext() method in S3ChecksumValidatingPublisher.ChecksumValidatingSubscriber
167 public void onNext(ByteBuffer byteBuffer) { in onNext() method in S3ChecksumValidatingPublisher.ChecksumSkippingSubscriber
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/async/ |
| H A D | SdkPublishersTest.java | 171 public void onNext(ByteBuffer byteBuffer) { in onNext() method in SdkPublishersTest.FakeByteBufferSubscriber
203 public void onNext(String s) { in onNext() method in SdkPublishersTest.FakeStringSubscriber
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/test/java/software/amazon/awssdk/core/internal/async/ |
| H A D | SplittingPublisherTest.java | 201 public void onNext(AsyncRequestBody requestBody) { in onNext() method in SplittingPublisherTest.OnlyRequestOnceSubscriber
238 public void onNext(ByteBuffer byteBuffer) { in onNext() method in SplittingPublisherTest.BaosSubscriber
|
| /aosp_15_r20/external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/test/ |
| H A D | FlowAsFluxTest.kt | 92 override fun onNext(t: Int) { in <lambda>() method
129 override fun onNext(t: Int) { in <lambda>() method
|
| /aosp_15_r20/external/kotlinx.coroutines/ui/kotlinx-coroutines-javafx/src/ |
| H A D | JavaFxDispatcher.kt | 105 fun onNext(cont: CancellableContinuation<Long>) { in onNext() method in kotlinx.coroutines.javafx.PulseTimer
|
| /aosp_15_r20/external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/internal/async/ |
| H A D | ChecksumCalculatingAsyncRequestBody.java | 188 public void onNext(ByteBuffer byteBuffer) { in onNext() method in ChecksumCalculatingAsyncRequestBody.ChecksumCalculatingSubscriber
260 public void onNext(ByteBuffer t) { in onNext() method in ChecksumCalculatingAsyncRequestBody.OnNextGuaranteedSubscriber
|
| /aosp_15_r20/external/grpc-grpc-java/binder/src/androidTest/java/io/grpc/binder/ |
| H A D | BinderChannelSmokeTest.java | 312 public void onNext(V value) { in onNext() method in BinderChannelSmokeTest.QueueingStreamObserver
335 public void onNext(V value) { in onNext() method in BinderChannelSmokeTest.ForwardingStreamObserver
|