Home
last modified time | relevance | path

Searched refs:onNext (Results 1 – 10 of 10) sorted by relevance

/packages/modules/Virtualization/android/TerminalApp/java/com/android/virtualization/terminal/
DDebianServiceImpl.kt50 responseObserver.onNext(reply) in reportVmActivePorts()
95 responseObserver.onNext(ShutdownRequestItem.newBuilder().build()) in openShutdownRequestQueue()
108 responseObserver.onNext(item) in setAvailableStorageBytes()
166 responseObserver.onNext(item) in onForwardingRequestReceived()
/packages/modules/Bluetooth/android/pandora/server/src/
DUtils.kt139 responseObserver.onNext(response) in grpcUnary()
187 .onEach { responseObserver.onNext(it) } in grpcBidirectionalStream()
207 override fun onNext(req: T) { in grpcBidirectionalStream() method
270 .onEach { responseObserver.onNext(it) } in grpcServerStream()
DLeAudio.kt170 override fun onNext(request: LeAudioPlaybackAudioRequest) { in leAudioPlaybackAudio() method
190 responseObserver.onNext(LeAudioPlaybackAudioResponse.getDefaultInstance()) in leAudioPlaybackAudio()
DAsha.kt250 override fun onNext(request: PlaybackAudioRequest) { in playbackAudio() method
269 responseObserver.onNext(PlaybackAudioResponse.getDefaultInstance()) in playbackAudio()
DA2dp.kt279 override fun onNext(request: PlaybackAudioRequest) { in playbackAudio() method
299 responseObserver.onNext(PlaybackAudioResponse.getDefaultInstance()) in playbackAudio()
/packages/modules/Bluetooth/framework/tests/bumble/src/android/bluetooth/pairing/
DPairingTest.java237 pairingEventAnswerObserver.onNext( in testBrEdrPairing_phoneInitiatedBrEdrInquiryOnlyJustWorks()
294 pairingEventAnswerObserver.onNext( in testBrEdrPairing_cancelBond_forUnrelatedDevice()
354 pairingEventAnswerObserver.onNext( in testBrEdrPairing_phoneInitiatedBrEdrInquiryOnlyJustWorksWhileSdpConnected()
929 pairingEventAnswerObserver.onNext( in testCreateLeSocket_BondLe()
998 pairingEventAnswerObserver.onNext( in testStep_BondBredr()
1183 pairingEventAnswerObserver.onNext( in testStep_BondLe()
DEncryptionChangeTest.java248 pairingEventAnswerObserver.onNext( in encryptionChangeSecureLeLink()
311 pairingEventAnswerObserver.onNext( in encryptionChangeSecureClassicLink()
DPairingWithDiscoveryTest.java270 pairingEventAnswerObserver.onNext( in testBondLe_AutoTransport()
358 pairingEventAnswerObserver.onNext( in testBondBrEdr_AutoTransport()
/packages/modules/DeviceLock/DeviceLockController/tests/robolectric/src/com/android/devicelockcontroller/provision/grpc/impl/
DDeviceCheckinClientImplTest.java973 responseObserver.onNext(response); in makeSucceedingService()
983 responseObserver.onNext(response); in makeSucceedingService()
993 responseObserver.onNext(response); in makeSucceedingService()
1003 responseObserver.onNext(response); in makeSucceedingService()
1014 responseObserver.onNext(response); in makeSucceedingService()
/packages/modules/Bluetooth/framework/tests/bumble/src/android/bluetooth/
DStreamObserverSpliterator.java82 public void onNext(T value) { in onNext() method in StreamObserverSpliterator