| /packages/modules/Bluetooth/android/pandora/server/src/ |
| D | MediaPlayer.kt | 51 override fun play(request: Empty, responseObserver: StreamObserver<Empty>) { in play()
52 grpcUnary<Empty>(scope, responseObserver) { in play()
58 override fun stop(request: Empty, responseObserver: StreamObserver<Empty>) { in stop()
59 grpcUnary<Empty>(scope, responseObserver) { in stop()
65 override fun pause(request: Empty, responseObserver: StreamObserver<Empty>) { in pause()
66 grpcUnary<Empty>(scope, responseObserver) { in pause()
72 override fun rewind(request: Empty, responseObserver: StreamObserver<Empty>) { in rewind()
73 grpcUnary<Empty>(scope, responseObserver) { in rewind()
79 override fun fastForward(request: Empty, responseObserver: StreamObserver<Empty>) { in fastForward()
80 grpcUnary<Empty>(scope, responseObserver) { in fastForward()
[all …]
|
| D | HfpHandsfree.kt | 71 responseObserver: StreamObserver<AnswerCallAsHandsfreeResponse> in answerCallAsHandsfree()
73 grpcUnary(scope, responseObserver) { in answerCallAsHandsfree()
84 responseObserver: StreamObserver<EndCallAsHandsfreeResponse> in endCallAsHandsfree()
86 grpcUnary(scope, responseObserver) { in endCallAsHandsfree()
102 responseObserver: StreamObserver<DeclineCallAsHandsfreeResponse> in declineCallAsHandsfree()
104 grpcUnary(scope, responseObserver) { in declineCallAsHandsfree()
112 responseObserver: StreamObserver<ConnectToAudioAsHandsfreeResponse> in connectToAudioAsHandsfree()
114 grpcUnary(scope, responseObserver) { in connectToAudioAsHandsfree()
122 responseObserver: StreamObserver<DisconnectFromAudioAsHandsfreeResponse> in disconnectFromAudioAsHandsfree()
124 grpcUnary(scope, responseObserver) { in disconnectFromAudioAsHandsfree()
[all …]
|
| D | Hfp.kt | 91 override fun enableSlc(request: EnableSlcRequest, responseObserver: StreamObserver<Empty>) { in enableSlc()
92 grpcUnary<Empty>(scope, responseObserver) { in enableSlc()
101 override fun disableSlc(request: DisableSlcRequest, responseObserver: StreamObserver<Empty>) { in disableSlc()
102 grpcUnary<Empty>(scope, responseObserver) { in disableSlc()
113 responseObserver: StreamObserver<Empty>, in setBatteryLevel()
115 grpcUnary<Empty>(scope, responseObserver) { in setBatteryLevel()
124 responseObserver: StreamObserver<DeclineCallResponse>, in declineCall()
126 grpcUnary(scope, responseObserver) { in declineCall()
134 responseObserver: StreamObserver<SetAudioPathResponse>, in setAudioPath()
136 grpcUnary(scope, responseObserver) { in setAudioPath()
[all …]
|
| D | A2dp.kt | 79 responseObserver: StreamObserver<OpenSourceResponse> in openSource()
81 grpcUnary<OpenSourceResponse>(scope, responseObserver) { in openSource()
117 responseObserver: StreamObserver<WaitSourceResponse> in waitSource()
119 grpcUnary<WaitSourceResponse>(scope, responseObserver) { in waitSource()
152 override fun start(request: StartRequest, responseObserver: StreamObserver<StartResponse>) { in start()
153 grpcUnary<StartResponse>(scope, responseObserver) { in start()
181 responseObserver: StreamObserver<SuspendResponse> in suspend()
183 grpcUnary<SuspendResponse>(scope, responseObserver) { in suspend()
209 responseObserver: StreamObserver<BoolValue> in isSuspended()
211 grpcUnary(scope, responseObserver) { in isSuspended()
[all …]
|
| D | Gatt.kt | 73 responseObserver: StreamObserver<ExchangeMTUResponse> in exchangeMTU()
75 grpcUnary<ExchangeMTUResponse>(mScope, responseObserver) { in exchangeMTU()
87 responseObserver: StreamObserver<WriteResponse> in writeAttFromHandle()
89 grpcUnary<WriteResponse>(mScope, responseObserver) { in writeAttFromHandle()
122 responseObserver: StreamObserver<DiscoverServicesResponse> in discoverServiceByUuid()
124 grpcUnary<DiscoverServicesResponse>(mScope, responseObserver) { in discoverServiceByUuid()
142 responseObserver: StreamObserver<DiscoverServicesResponse> in discoverServices()
144 grpcUnary<DiscoverServicesResponse>(mScope, responseObserver) { in discoverServices()
157 responseObserver: StreamObserver<DiscoverServicesSdpResponse> in discoverServicesSdp()
159 grpcUnary<DiscoverServicesSdpResponse>(mScope, responseObserver) { in discoverServicesSdp()
[all …]
|
| D | Rfcomm.kt | 68 responseObserver: StreamObserver<ConnectionResponse>, in connectToServer()
70 grpcUnary(scope, responseObserver) { in connectToServer()
100 responseObserver: StreamObserver<DisconnectionResponse>, in disconnect()
102 grpcUnary(scope, responseObserver) { in disconnect()
117 responseObserver: StreamObserver<StartServerResponse>, in startServer()
119 grpcUnary(scope, responseObserver) { in startServer()
137 responseObserver: StreamObserver<AcceptConnectionResponse>, in acceptConnection()
139 grpcUnary(scope, responseObserver) { in acceptConnection()
161 responseObserver: StreamObserver<TxResponse>, in send()
163 grpcUnary(scope, responseObserver) { in send()
[all …]
|
| D | Utils.kt | 132 responseObserver: StreamObserver<T>, in grpcUnary()
139 responseObserver.onNext(response) in grpcUnary()
140 responseObserver.onCompleted() in grpcUnary()
145 responseObserver.onError( in grpcUnary()
177 responseObserver: StreamObserver<U>, in grpcBidirectionalStream()
182 val serverCallStreamObserver = responseObserver as ServerCallStreamObserver<T> in grpcBidirectionalStream()
187 .onEach { responseObserver.onNext(it) } in grpcBidirectionalStream()
190 responseObserver.onCompleted() in grpcBidirectionalStream()
197 responseObserver.onError( in grpcBidirectionalStream()
213 responseObserver.onError( in grpcBidirectionalStream()
[all …]
|
| D | L2cap.kt | 82 responseObserver: StreamObserver<ListenL2CAPChannelResponse>, in listenL2CAPChannel()
84 grpcUnary(scope, responseObserver) { in listenL2CAPChannel()
100 responseObserver: StreamObserver<AcceptL2CAPChannelResponse>, in acceptL2CAPChannel()
102 grpcUnary(scope, responseObserver) { in acceptL2CAPChannel()
124 responseObserver: StreamObserver<CreateLECreditBasedChannelResponse>, in createLECreditBasedChannel()
129 grpcUnary(scope, responseObserver) { in createLECreditBasedChannel()
158 responseObserver: StreamObserver<SendDataResponse>, in sendData()
160 grpcUnary(scope, responseObserver) { in sendData()
182 responseObserver: StreamObserver<ReceiveDataResponse>, in receiveData()
184 grpcUnary(scope, responseObserver) { in receiveData()
|
| D | Asha.kt | 82 responseObserver: StreamObserver<WaitPeripheralResponse> in waitPeripheral()
84 grpcUnary<WaitPeripheralResponse>(scope, responseObserver) { in waitPeripheral()
108 override fun start(request: StartRequest, responseObserver: StreamObserver<StartResponse>) { in start()
109 grpcUnary<StartResponse>(scope, responseObserver) { in start()
216 override fun stop(request: StopRequest, responseObserver: StreamObserver<StopResponse>) { in stop()
217 grpcUnary<StopResponse>(scope, responseObserver) { in stop()
227 responseObserver: StreamObserver<PlaybackAudioResponse> in playbackAudio()
231 responseObserver.onError( in playbackAudio()
259 responseObserver.onError( in playbackAudio()
266 responseObserver.onError(t) in playbackAudio()
[all …]
|
| D | Os.kt | 44 override fun log(request: LogRequest, responseObserver: StreamObserver<LogResponse>) { in log()
45 grpcUnary(scope, responseObserver) { in log()
53 responseObserver: StreamObserver<Empty> in setAccessPermission()
55 grpcUnary<Empty>(scope, responseObserver) { in setAccessPermission()
70 override fun sendPing(request: SendPingRequest, responseObserver: StreamObserver<Empty>) { in sendPing()
71 grpcUnary<Empty>(scope, responseObserver) { in sendPing()
|
| D | Host.kt | 162 override fun factoryReset(request: Empty, responseObserver: StreamObserver<Empty>) { in factoryReset()
163 grpcUnary<Empty>(scope, responseObserver, timeout = 30) { in factoryReset()
193 override fun reset(request: Empty, responseObserver: StreamObserver<Empty>) { in reset()
194 grpcUnary<Empty>(scope, responseObserver) { in reset()
208 responseObserver: StreamObserver<ReadLocalAddressResponse> in readLocalAddress()
210 grpcUnary<ReadLocalAddressResponse>(scope, responseObserver) { in readLocalAddress()
284 responseObserver: StreamObserver<WaitConnectionResponse> in waitConnection()
286 grpcUnary(scope, responseObserver) { in waitConnection()
313 responseObserver: StreamObserver<Empty> in waitDisconnection()
315 grpcUnary(scope, responseObserver) { in waitDisconnection()
[all …]
|
| D | Opp.kt | 88 responseObserver: StreamObserver<Empty> in openRfcommChannel()
90 grpcUnary<Empty>(scope, responseObserver) { in openRfcommChannel()
99 responseObserver: StreamObserver<Empty> in openL2capChannel()
101 grpcUnary<Empty>(scope, responseObserver) { in openL2capChannel()
110 responseObserver: StreamObserver<AcceptPutOperationResponse> in acceptPutOperation()
112 grpcUnary<AcceptPutOperationResponse>(scope, responseObserver) { in acceptPutOperation()
|
| D | Pan.kt | 75 responseObserver: StreamObserver<EnableTetheringResponse> in enableTethering()
77 grpcUnary<EnableTetheringResponse>(mScope, responseObserver) { in enableTethering()
93 responseObserver: StreamObserver<ConnectPanResponse> in connectPan()
95 grpcUnary<ConnectPanResponse>(mScope, responseObserver) { in connectPan()
|
| D | SecurityStorage.kt | 67 override fun isBonded(request: IsBondedRequest, responseObserver: StreamObserver<BoolValue>) { in isBonded()
68 grpcUnary(globalScope, responseObserver) { in isBonded()
84 override fun deleteBond(request: DeleteBondRequest, responseObserver: StreamObserver<Empty>) { in deleteBond()
85 grpcUnary(globalScope, responseObserver) { in deleteBond()
|
| D | A2dpSink.kt | 70 responseObserver: StreamObserver<WaitSinkResponse> in waitSink()
72 grpcUnary<WaitSinkResponse>(scope, responseObserver) { in waitSink()
103 override fun close(request: CloseRequest, responseObserver: StreamObserver<CloseResponse>) { in close()
104 grpcUnary<CloseResponse>(scope, responseObserver) { in close()
|
| D | Security.kt | 116 override fun secure(request: SecureRequest, responseObserver: StreamObserver<SecureResponse>) { in <lambda>()
117 grpcUnary(globalScope, responseObserver) { in <lambda>()
208 responseObserver: StreamObserver<WaitSecurityResponse> in <lambda>()
210 grpcUnary(globalScope, responseObserver) { in <lambda>()
234 responseObserver: StreamObserver<PairingEvent> in <lambda>()
236 grpcBidirectionalStream(globalScope, responseObserver) { in <lambda>()
|
| D | Map.kt | 38 override fun sendSMS(request: Empty, responseObserver: StreamObserver<Empty>) { in sendSMS()
39 grpcUnary<Empty>(scope, responseObserver) { in sendSMS()
|
| D | Hid.kt | 51 responseObserver: StreamObserver<SendHostReportResponse>, in sendHostReport()
53 grpcUnary(scope, responseObserver) { in sendHostReport()
|
| D | LeAudio.kt | 71 override fun open(request: OpenRequest, responseObserver: StreamObserver<Empty>) { in open()
72 grpcUnary<Empty>(scope, responseObserver) { in open()
|
| /packages/apps/Dialer/java/com/android/voicemail/impl/ |
| D | VoicemailTranscriptionServiceGrpc.java | 122 ….internal.communications.voicemailtranscription.v1.TranscribeVoicemailResponse> responseObserver) { in transcribeVoicemail() argument
123 asyncUnimplementedUnaryCall(METHOD_TRANSCRIBE_VOICEMAIL, responseObserver); in transcribeVoicemail()
133 …rnal.communications.voicemailtranscription.v1.TranscribeVoicemailAsyncResponse> responseObserver) { in transcribeVoicemailAsync() argument
134 asyncUnimplementedUnaryCall(METHOD_TRANSCRIBE_VOICEMAIL_ASYNC, responseObserver); in transcribeVoicemailAsync()
144 …google.internal.communications.voicemailtranscription.v1.GetTranscriptResponse> responseObserver) { in getTranscript() argument
145 asyncUnimplementedUnaryCall(METHOD_GET_TRANSCRIPT, responseObserver); in getTranscript()
155 …nal.communications.voicemailtranscription.v1.SendTranscriptionFeedbackResponse> responseObserver) { in sendTranscriptionFeedback() argument
156 asyncUnimplementedUnaryCall(METHOD_SEND_TRANSCRIPTION_FEEDBACK, responseObserver); in sendTranscriptionFeedback()
220 ….internal.communications.voicemailtranscription.v1.TranscribeVoicemailResponse> responseObserver) { in transcribeVoicemail() argument
222 … getChannel().newCall(METHOD_TRANSCRIBE_VOICEMAIL, getCallOptions()), request, responseObserver); in transcribeVoicemail() local
[all …]
|
| /packages/modules/DeviceLock/DeviceLockController/tests/robolectric/src/com/android/devicelockcontroller/provision/grpc/impl/ |
| D | DeviceCheckinClientImplTest.java | 749 StreamObserver<GetDeviceCheckinStatusResponse> responseObserver) { in makeSucceedingService()
754 responseObserver.onNext(response); in makeSucceedingService()
755 responseObserver.onCompleted(); in makeSucceedingService()
760 StreamObserver<IsDeviceInApprovedCountryResponse> responseObserver) { in makeSucceedingService() argument
764 responseObserver.onNext(response); in makeSucceedingService()
765 responseObserver.onCompleted(); in makeSucceedingService()
770 StreamObserver<PauseDeviceProvisioningResponse> responseObserver) { in makeSucceedingService() argument
774 responseObserver.onNext(response); in makeSucceedingService()
775 responseObserver.onCompleted(); in makeSucceedingService()
780 StreamObserver<ReportDeviceProvisionStateResponse> responseObserver) { in makeSucceedingService() argument
[all …]
|
| /packages/modules/Bluetooth/framework/tests/bumble/src/android/bluetooth/pairing/ |
| D | PairingTest.java | 313 StreamObserverSpliterator<SecureResponse> responseObserver = in testCancelBondLe_WithGattServiceDiscovery() local
319 SecureResponse secureResponse = responseObserver.iterator().next(); in testCancelBondLe_WithGattServiceDiscovery()
364 StreamObserverSpliterator<SecureResponse> responseObserver = in testBondLe_WithGattServiceDiscovery() local
370 SecureResponse secureResponse = responseObserver.iterator().next(); in testBondLe_WithGattServiceDiscovery()
429 StreamObserverSpliterator<SecureResponse> responseObserver = in helper_OutgoingGattServiceDiscoveryWithIncomingLePairing() local
437 responseObserver); in helper_OutgoingGattServiceDiscoveryWithIncomingLePairing() local
478 return responseObserver; in helper_OutgoingGattServiceDiscoveryWithIncomingLePairing()
|
| /packages/modules/Bluetooth/framework/tests/bumble/src/android/bluetooth/ |
| D | LeAdvertisingTest.java | 74 StreamObserverSpliterator<ScanningResponse> responseObserver = in scanWithBumble() local
79 .scan(ScanRequest.newBuilder().build(), responseObserver); in scanWithBumble() local
80 Iterator<ScanningResponse> responseObserverIterator = responseObserver.iterator(); in scanWithBumble()
|
| D | LeScanningTest.java | 415 StreamObserverSpliterator<AdvertiseResponse> responseObserver = in advertiseWithBumble() local
417 mBumble.host().advertise(requestBuilder.build(), responseObserver); in advertiseWithBumble() local
|
| D | GattClientTest.java | 433 StreamObserverSpliterator<AdvertiseResponse> responseObserver = in advertiseWithBumble() local
436 mBumble.host().advertise(request, responseObserver); in advertiseWithBumble()
|