| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/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
149 override fun onNext(t: String) { in <lambda>() method
|
| D | FlowAsPublisherTest.kt | 37 override fun onNext(t: Int) { in testErrorOnCancellationIsReported() method
68 override fun onNext(t: Int) { in testCancellationIsNotReported() method
|
| D | PublisherBackpressureTest.kt | 37 override fun onNext(t: String) { in <lambda>() method
|
| D | IterableFlowTckTest.kt | 66 override fun onNext(aLong: Long) { in testStackOverflowTrampoline() method
103 override fun onNext(aLong: Long) { in testConcurrentRequest() 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/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | StreamObserver.java | 52 void onNext(V value); in onNext() method
|
| D | ServerCalls.java | 333 public void onNext(RespT response) { in onNext() method in ServerCalls.ServerCallStreamObserverImpl
432 public void onNext(V value) { in onNext() method in ServerCalls.NoopStreamObserver
|
| /external/kotlinx.coroutines/ui/kotlinx-coroutines-javafx/src/ |
| D | JavaFxDispatcher.kt | 113 fun onNext(cont: CancellableContinuation<Long>) { in onNext() method
|
| /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-rx2/src/ |
| D | RxChannel.kt | 90 override fun onNext(t: T) { in consumeEach() method in kotlinx.coroutines.rx2.SubscriptionChannel
|
| D | RxAwait.kt | 178 override fun onNext(t: T) { in toString() method
|
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| D | TestServiceImpl.java | 152 public void onNext(StreamingInputCallRequest message) { in streamingInputCall() method
|
| D | Http2Client.java | 289 public void onNext(SimpleResponse value) { in onNext() method in Http2Client.Tester.RstStreamObserver
|
| /external/grpc-grpc-java/alts/src/test/java/io/grpc/alts/internal/ |
| D | AltsHandshakerStubTest.java | 151 public void onNext(final HandshakerReq req) { in onNext() method in AltsHandshakerStubTest.MockWriter
|
| /external/kotlinx.coroutines/reactive/kotlinx-coroutines-reactive/src/ |
| D | Channel.kt | 103 override fun onNext(t: T) { in consumeEach() method in kotlinx.coroutines.reactive.SubscriptionChannel
|
| D | Await.kt | 118 override fun onNext(t: T) { in toString() method
|
| /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
| D | ConcurrencyTest.java | 90 public void onNext(StreamingOutputCallResponse response) { in onNext() method in ConcurrencyTest.SignalingResponseObserver
|
| D | NettyFlowControlTest.java | 208 public void onNext(StreamingOutputCallResponse value) { in onNext() method in NettyFlowControlTest.TestStreamObserver
|
| /external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/routeguide/ |
| D | RouteGuideServer.java | 178 public void onNext(Point point) { in recordRoute() method
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/java/benchmarks/flow/scrabble/optimizations/ |
| D | FlowableSplit.java | 125 public void onNext(String t) { in onNext() method in FlowableSplit.SplitSubscriber
|
| /external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/ |
| D | LoadClient.java | 468 public void onNext(ByteBuf value) { in run() method
|