| /external/pigweed/pw_rpc/ts/ |
| D | client_test.ts | 304 const onNext = jest.fn(); constant
328 const onNext = jest.fn(); constant
357 const onNext = jest.fn(); constant
422 const onNext = jest.fn(); constant
448 const onNext = jest.fn(); constant
481 const onNext = jest.fn(); constant
518 const onNext = jest.fn(); constant
548 const onNext = jest.fn(); constant
574 const onNext = jest.fn(); constant
799 const onNext = jest.fn(); constant
|
| /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
|
| D | IterableFlowTckTest.kt | 62 override fun onNext(aLong: Long) { in testStackOverflowTrampoline() method
99 override fun onNext(aLong: Long) { in testConcurrentRequest() method
|
| D | PublisherBackpressureTest.kt | 37 override fun onNext(t: String) { 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
|
| D | PublisherBackpressureTest.kt | 37 override fun onNext(t: String) { in <lambda>() method
|
| D | PublisherAsFlowTest.kt | 15 var onNext = 0 in <lambda>() variable
|
| /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
|
| D | BaristaTest.java | 60 public void onNext(CoffeeResponse value) { in onNext() method in BaristaTest.CoffeeResponseObserver
|
| /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
|
| D | FlowAsObservableTest.kt | 158 override fun onNext(t: Int) { in <lambda>() method
191 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
|
| D | FlowAsObservableTest.kt | 158 override fun onNext(t: Int) { in <lambda>() method
191 override fun onNext(t: Int) { in <lambda>() method
|
| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | StreamObserver.java | 52 void onNext(V value); in onNext() method
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactor/test/ |
| D | FlowAsFluxTest.kt | 91 override fun onNext(t: Int) { in <lambda>() method
128 override fun onNext(t: Int) { in <lambda>() method
|
| /external/pigweed/ts/device/ |
| D | index_test.ts | 113 const onNext = jest.fn(); constant
|
| /external/kotlinx.coroutines/ui/kotlinx-coroutines-javafx/src/ |
| D | JavaFxDispatcher.kt | 109 fun onNext(cont: CancellableContinuation<Long>) { in onNext() method in kotlinx.coroutines.javafx.PulseTimer
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/internal/testing/ |
| D | StreamRecorder.java | 54 public void onNext(T value) { in onNext() method in StreamRecorder
|
| /external/grpc-grpc-java/testing/src/main/java/io/grpc/testing/ |
| D | StreamRecorder.java | 59 public void onNext(T value) { in onNext() method in StreamRecorder
|
| /external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/ |
| D | AltsHandshakerStub.java | 85 public void onNext(HandshakerResp resp) { in onNext() method in AltsHandshakerStub.Reader
|