| /external/pigweed/pw_rpc/ts/ |
| D | client_test.ts | 305 const onNext = jasmine.createSpy(); constant
329 const onNext = jasmine.createSpy(); constant
358 const onNext = jasmine.createSpy(); constant
420 const onNext = jasmine.createSpy(); constant
446 const onNext = jasmine.createSpy(); constant
479 const onNext = jasmine.createSpy(); constant
516 const onNext = jasmine.createSpy(); constant
546 const onNext = jasmine.createSpy(); constant
572 const onNext = jasmine.createSpy(); constant
789 const onNext = jasmine.createSpy(); constant
|
| /external/pigweed/pw_rpc/java/main/dev/pigweed/pw_rpc/ |
| D | StreamObserverCall.java | 123 public void onNext(ResponseT value) { in onNext() method in StreamObserverCall.UnaryResponseFuture
145 private final Consumer<ResponseT> onNext; field in StreamObserverCall.StreamResponseFuture
148 RpcManager rpcs, PendingRpc rpc, Consumer<ResponseT> onNext, @Nullable RequestT request) { in StreamResponseFuture()
155 public void onNext(ResponseT value) { in onNext() method in StreamObserverCall.StreamResponseFuture
231 void onNext(ByteString payload) { in onNext() method in StreamObserverCall
|
| D | MethodClient.java | 98 MessageLite request, Consumer<? extends MessageLite> onNext) { in invokeServerStreamingFuture()
165 Consumer<ResponseT> onNext) { in invokeBidirectionalStreamingFuture()
|
| D | StreamObserver.java | 22 void onNext(T value); in onNext() method
|
| /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/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
|
| /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 | ObservableAsFlowTest.kt | 20 var onNext = 0 in testCancellation() variable
|
| 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
|
| /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/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/testing/ |
| D | StreamRecorder.java | 59 public void onNext(T value) { in onNext() method in StreamRecorder
|
| /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/alts/src/main/java/io/grpc/alts/internal/ |
| D | AltsHandshakerStub.java | 85 public void onNext(HandshakerResp resp) { in onNext() method in AltsHandshakerStub.Reader
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx3/src/ |
| D | RxChannel.kt | 81 override fun onNext(t: T) { in collect() method in kotlinx.coroutines.rx3.SubscriptionChannel
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-rx2/src/ |
| D | RxChannel.kt | 68 override fun onNext(t: T) { in onNext() method in kotlinx.coroutines.rx2.SubscriptionChannel
|