| /external/pigweed/pw_rpc/ts/ |
| 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 …]
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/test/ |
| D | FlowAsPublisherTest.kt | 38 override fun onNext(t: Int) { in <lambda>() method
68 override fun onNext(t: Int) { in <lambda>() method
96 override fun onNext(t: Int) { in <lambda>() method
133 override fun onNext(t: Int) { in <lambda>() method
|
| D | PublishTest.kt | 27 override fun onNext(t: Int?) { expectUnreached() } in <lambda>() method
50 override fun onNext(t: Int) { in <lambda>() method
75 override fun onNext(t: Int) { expectUnreached() } in <lambda>() method
116 override fun onNext(t: Unit?) { in <lambda>() method
175 override fun onNext(t: String) { in <lambda>() method
211 override fun onNext(t: Int) { in <lambda>() method
|
| /external/pigweed/pw_rpc/java/main/dev/pigweed/pw_rpc/ |
| 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()
|
| D | StreamObserver.java | 22 void onNext(T value); in onNext() method
|
| D | MethodClient.java | 103 MessageLite request, Consumer<? extends MessageLite> onNext) { in invokeServerStreamingFuture()
169 Consumer<ResponseT> onNext) { in invokeBidirectionalStreamingFuture()
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-jdk9/test/ |
| D | PublishTest.kt | 23 override fun onNext(t: Int?) { expectUnreached() } in <lambda>() method
46 override fun onNext(t: Int) { in <lambda>() method
71 override fun onNext(t: Int) { expectUnreached() } in <lambda>() method
112 override fun onNext(t: Unit?) { in <lambda>() method
171 override fun onNext(t: String) { in <lambda>() method
207 override fun onNext(t: Int) { in <lambda>() method
|
| D | FlowAsPublisherTest.kt | 37 override fun onNext(t: Int) { in testErrorOnCancellationIsReported() method
67 override fun onNext(t: Int) { in testCancellationIsNotReported() method
|
| /external/dagger2/javatests/dagger/grpc/functional/server/ |
| D | FriendlyBarista.java | 52 public void onNext(CoffeeRequest value) { in clientStreamingGetCoffee() method
85 public void onNext(CoffeeRequest value) { in bidiStreamingGetCoffee() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/test/ |
| D | FlowAsFlowableTest.kt | 32 override fun onNext(t: Int) { in <lambda>() method
69 override fun onNext(t: Int) { in <lambda>() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/test/ |
| D | FlowAsFlowableTest.kt | 32 override fun onNext(t: Int) { in <lambda>() method
69 override fun onNext(t: Int) { in <lambda>() method
|
| /external/sdk-platform-java/gax-java/gax/src/main/java/com/google/api/gax/tracing/ |
| 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
|
| /external/aws-sdk-java-v2/services/s3/src/main/java/software/amazon/awssdk/services/s3/internal/checksums/ |
| 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
|
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| D | TestServiceImpl.java | 185 public void onNext(StreamingInputCallRequest message) { in streamingInputCall() method
215 public void onNext(StreamingOutputCallRequest request) { in fullDuplexCall() method
|
| /external/sdk-platform-java/gax-java/gax/src/main/java/com/google/api/gax/rpc/ |
| D | ApiStreamObserver.java | 70 void onNext(V value); in onNext() method
|
| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | StreamObserver.java | 62 void onNext(V value); in onNext() method
|
| /external/aws-sdk-java-v2/http-clients/aws-crt-client/src/test/java/software/amazon/awssdk/http/crt/ |
| D | CrtHttpClientTestUtils.java | 29 public void onNext(ByteBuffer byteBuffer) { in createDummySubscriber() method in CrtHttpClientTestUtils
|
| /external/aws-sdk-java-v2/http-clients/netty-nio-client/src/main/java/software/amazon/awssdk/http/nio/netty/internal/nrs/ |
| D | CancelledSubscriber.java | 45 public void onNext(T t) { in onNext() method in CancelledSubscriber
|
| /external/aws-sdk-java-v2/core/sdk-core/src/main/java/software/amazon/awssdk/core/async/ |
| D | DrainingSubscriber.java | 34 public void onNext(T t) { in onNext() method in DrainingSubscriber
|
| /external/aws-sdk-java-v2/utils/src/test/java/software/amazon/awssdk/utils/async/ |
| D | InputStreamSubscriberTckTest.java | 55 public void onNext(ByteBuffer next) { in createSubscriber() method in InputStreamSubscriberTckTest
|
| D | ByteBufferStoringSubscriberTckTest.java | 55 public void onNext(ByteBuffer next) { in createSubscriber() method in ByteBufferStoringSubscriberTckTest
|
| /external/sdk-platform-java/gax-java/gax-grpc/src/main/java/com/google/api/gax/grpc/ |
| D | StreamObserverDelegate.java | 49 public void onNext(V v) { in onNext() method in StreamObserverDelegate
|
| D | ApiStreamObserverDelegate.java | 49 public void onNext(V v) { in onNext() method in ApiStreamObserverDelegate
|
| /external/aws-sdk-java-v2/services-custom/s3-transfer-manager/src/test/java/software/amazon/awssdk/transfer/s3/internal/ |
| D | AsyncBufferingSubscriberTckTest.java | 54 public void onNext(String item) { in createSubscriber() method in AsyncBufferingSubscriberTckTest
|
| /external/sdk-platform-java/gax-java/gax-grpc/src/test/java/com/google/api/gax/grpc/testing/ |
| D | MockStreamObserver.java | 46 public void onNext(T message) { in onNext() method in MockStreamObserver
|