Home
last modified time | relevance | path

Searched refs:responseObserver (Results 1 – 25 of 31) sorted by relevance

12

/packages/modules/Bluetooth/android/pandora/server/src/
DMediaPlayer.kt51 override fun play(request: Empty, responseObserver: StreamObserver<Empty>) { in play()
52 grpcUnary<Empty>(scope, responseObserver) { in play()
58 override fun playUpdated(request: Empty, responseObserver: StreamObserver<Empty>) { in playUpdated()
59 grpcUnary<Empty>(scope, responseObserver) { in playUpdated()
65 override fun stop(request: Empty, responseObserver: StreamObserver<Empty>) { in stop()
66 grpcUnary<Empty>(scope, responseObserver) { in stop()
72 override fun pause(request: Empty, responseObserver: StreamObserver<Empty>) { in pause()
73 grpcUnary<Empty>(scope, responseObserver) { in pause()
79 override fun rewind(request: Empty, responseObserver: StreamObserver<Empty>) { in rewind()
80 grpcUnary<Empty>(scope, responseObserver) { in rewind()
[all …]
DHfpHandsfree.kt73 responseObserver: StreamObserver<AnswerCallAsHandsfreeResponse>, in answerCallAsHandsfree()
75 grpcUnary(scope, responseObserver) { in answerCallAsHandsfree()
86 responseObserver: StreamObserver<EndCallAsHandsfreeResponse>, in endCallAsHandsfree()
88 grpcUnary(scope, responseObserver) { in endCallAsHandsfree()
104 responseObserver: StreamObserver<DeclineCallAsHandsfreeResponse>, in declineCallAsHandsfree()
106 grpcUnary(scope, responseObserver) { in declineCallAsHandsfree()
114 responseObserver: StreamObserver<ConnectToAudioAsHandsfreeResponse>, in connectToAudioAsHandsfree()
116 grpcUnary(scope, responseObserver) { in connectToAudioAsHandsfree()
124 responseObserver: StreamObserver<DisconnectFromAudioAsHandsfreeResponse>, in disconnectFromAudioAsHandsfree()
126 grpcUnary(scope, responseObserver) { in disconnectFromAudioAsHandsfree()
[all …]
DHfp.kt93 override fun enableSlc(request: EnableSlcRequest, responseObserver: StreamObserver<Empty>) { in enableSlc()
94 grpcUnary<Empty>(scope, responseObserver) { in enableSlc()
103 override fun disableSlc(request: DisableSlcRequest, responseObserver: StreamObserver<Empty>) { in disableSlc()
104 grpcUnary<Empty>(scope, responseObserver) { in disableSlc()
115 responseObserver: StreamObserver<Empty>, in setBatteryLevel()
117 grpcUnary<Empty>(scope, responseObserver) { in setBatteryLevel()
126 responseObserver: StreamObserver<DeclineCallResponse>, in declineCall()
128 grpcUnary(scope, responseObserver) { in declineCall()
136 responseObserver: StreamObserver<SetAudioPathResponse>, in setAudioPath()
138 grpcUnary(scope, responseObserver) { in setAudioPath()
[all …]
DHap.kt138 responseObserver: StreamObserver<GetFeaturesResponse>, in <lambda>()
140 grpcUnary<GetFeaturesResponse>(scope, responseObserver) { in <lambda>()
151 responseObserver: StreamObserver<GetPresetRecordResponse>, in <lambda>()
153 grpcUnary<GetPresetRecordResponse>(scope, responseObserver) { in <lambda>()
178 responseObserver: StreamObserver<GetAllPresetRecordsResponse>, in <lambda>()
180 grpcUnary<GetAllPresetRecordsResponse>(scope, responseObserver) { in <lambda>()
205 responseObserver: StreamObserver<Empty>, in <lambda>()
207 grpcUnary<Empty>(scope, responseObserver) { in <lambda>()
219 responseObserver: StreamObserver<Empty>, in <lambda>()
221 grpcUnary<Empty>(scope, responseObserver) { in <lambda>()
[all …]
DGatt.kt74 responseObserver: StreamObserver<ExchangeMTUResponse>, in exchangeMTU()
76 grpcUnary<ExchangeMTUResponse>(mScope, responseObserver) { in exchangeMTU()
88 responseObserver: StreamObserver<WriteResponse>, in writeAttFromHandle()
90 grpcUnary<WriteResponse>(mScope, responseObserver) { in writeAttFromHandle()
123 responseObserver: StreamObserver<DiscoverServicesResponse>, in discoverServiceByUuid()
125 grpcUnary<DiscoverServicesResponse>(mScope, responseObserver) { in discoverServiceByUuid()
143 responseObserver: StreamObserver<DiscoverServicesResponse>, in discoverServices()
145 grpcUnary<DiscoverServicesResponse>(mScope, responseObserver) { in discoverServices()
158 responseObserver: StreamObserver<DiscoverServicesSdpResponse>, in discoverServicesSdp()
160 grpcUnary<DiscoverServicesSdpResponse>(mScope, responseObserver) { in discoverServicesSdp()
[all …]
DVcp.kt71 responseObserver: StreamObserver<Empty>, in setDeviceVolume()
73 grpcUnary<Empty>(scope, responseObserver) { in setDeviceVolume()
86 responseObserver: StreamObserver<Empty>, in setVolumeOffset()
88 grpcUnary<Empty>(scope, responseObserver) { in setVolumeOffset()
99 override fun waitConnect(request: WaitConnectRequest, responseObserver: StreamObserver<Empty>) { in waitConnect()
100 grpcUnary<Empty>(scope, responseObserver) { in waitConnect()
120 responseObserver: StreamObserver<Empty>, in setGainSetting()
122 grpcUnary<Empty>(scope, responseObserver) { in setGainSetting()
134 override fun setMute(request: SetMuteRequest, responseObserver: StreamObserver<Empty>) { in setMute()
135 grpcUnary<Empty>(scope, responseObserver) { in setMute()
[all …]
DRfcomm.kt66 responseObserver: StreamObserver<ConnectionResponse>, in connectToServer()
68 grpcUnary(scope, responseObserver) { in connectToServer()
96 responseObserver: StreamObserver<DisconnectionResponse>, in disconnect()
98 grpcUnary(scope, responseObserver) { in disconnect()
115 responseObserver: StreamObserver<StartServerResponse>, in startServer()
117 grpcUnary(scope, responseObserver) { in startServer()
136 responseObserver: StreamObserver<AcceptConnectionResponse>, in acceptConnection()
138 grpcUnary(scope, responseObserver) { in acceptConnection()
161 override fun send(request: TxRequest, responseObserver: StreamObserver<TxResponse>) { in send()
162 grpcUnary(scope, responseObserver) { in send()
[all …]
DLeAudio.kt79 override fun open(request: OpenRequest, responseObserver: StreamObserver<Empty>) { in open()
80 grpcUnary<Empty>(scope, responseObserver) { in open()
108 … override fun leAudioStart(request: LeAudioStartRequest, responseObserver: StreamObserver<Empty>) { in leAudioStart()
109 grpcUnary<Empty>(scope, responseObserver) { in leAudioStart()
131 override fun leAudioStop(request: LeAudioStopRequest, responseObserver: StreamObserver<Empty>) { in leAudioStop()
132 grpcUnary<Empty>(scope, responseObserver) { in leAudioStop()
143 responseObserver: StreamObserver<LeAudioPlaybackAudioResponse> in leAudioPlaybackAudio()
148 responseObserver.onError( in leAudioPlaybackAudio()
174 responseObserver.onError( in leAudioPlaybackAudio()
184 responseObserver.onError( in leAudioPlaybackAudio()
[all …]
DA2dp.kt88 responseObserver: StreamObserver<OpenSourceResponse>, in openSource()
90 grpcUnary<OpenSourceResponse>(scope, responseObserver) { in openSource()
119 responseObserver: StreamObserver<WaitSourceResponse>, in waitSource()
121 grpcUnary<WaitSourceResponse>(scope, responseObserver) { in waitSource()
147 override fun start(request: StartRequest, responseObserver: StreamObserver<StartResponse>) { in start()
148 grpcUnary<StartResponse>(scope, responseObserver) { in start()
181 responseObserver: StreamObserver<SuspendResponse>, in suspend()
183 grpcUnary<SuspendResponse>(scope, responseObserver) { in suspend()
213 responseObserver: StreamObserver<BoolValue>, in isSuspended()
215 grpcUnary(scope, responseObserver) { in isSuspended()
[all …]
DUtils.kt132 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 …]
DL2cap.kt62 responseObserver: StreamObserver<ConnectResponse>, in connect()
64 grpcUnary(scope, responseObserver) { in connect()
88 responseObserver: StreamObserver<WaitConnectionResponse>, in waitConnection()
90 grpcUnary(scope, responseObserver) { in waitConnection()
134 responseObserver: StreamObserver<DisconnectResponse>, in disconnect()
136 grpcUnary(scope, responseObserver) { in disconnect()
158 responseObserver: StreamObserver<WaitDisconnectionResponse>, in waitDisconnection()
160 grpcUnary(scope, responseObserver) { in waitDisconnection()
170 override fun send(request: SendRequest, responseObserver: StreamObserver<SendResponse>) { in send()
171 grpcUnary(scope, responseObserver) { in send()
[all …]
DAsha.kt83 responseObserver: StreamObserver<WaitPeripheralResponse>, in waitPeripheral()
85 grpcUnary<WaitPeripheralResponse>(scope, responseObserver) { in waitPeripheral()
107 override fun start(request: StartRequest, responseObserver: StreamObserver<StartResponse>) { in start()
108 grpcUnary<StartResponse>(scope, responseObserver) { in start()
213 override fun stop(request: StopRequest, responseObserver: StreamObserver<StopResponse>) { in stop()
214 grpcUnary<StopResponse>(scope, responseObserver) { in stop()
224 responseObserver: StreamObserver<PlaybackAudioResponse> in playbackAudio()
228 responseObserver.onError( in playbackAudio()
256 responseObserver.onError( in playbackAudio()
264 responseObserver.onError(t) in playbackAudio()
[all …]
DHost.kt164 override fun factoryReset(request: Empty, responseObserver: StreamObserver<Empty>) { in factoryReset()
165 grpcUnary<Empty>(scope, responseObserver, timeout = 30) { in factoryReset()
204 override fun reset(request: Empty, responseObserver: StreamObserver<Empty>) { in reset()
205 grpcUnary<Empty>(scope, responseObserver) { in reset()
219 responseObserver: StreamObserver<ReadLocalAddressResponse>, in readLocalAddress()
221 grpcUnary<ReadLocalAddressResponse>(scope, responseObserver) { in readLocalAddress()
295 responseObserver: StreamObserver<WaitConnectionResponse>, in waitConnection()
297 grpcUnary(scope, responseObserver) { in waitConnection()
324 responseObserver: StreamObserver<Empty>, in waitDisconnection()
326 grpcUnary(scope, responseObserver) { in waitDisconnection()
[all …]
DOs.kt44 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()
DOpp.kt88 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()
DPan.kt77 responseObserver: StreamObserver<EnableTetheringResponse>, in enableTethering()
79 grpcUnary<EnableTetheringResponse>(mScope, responseObserver) { in enableTethering()
95 responseObserver: StreamObserver<ConnectPanResponse>, in connectPan()
97 grpcUnary<ConnectPanResponse>(mScope, responseObserver) { in connectPan()
DSecurityStorage.kt67 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()
DA2dpSink.kt73 responseObserver: StreamObserver<WaitSinkResponse>, in waitSink()
75 grpcUnary<WaitSinkResponse>(scope, responseObserver) { in waitSink()
103 override fun close(request: CloseRequest, responseObserver: StreamObserver<CloseResponse>) { in close()
104 grpcUnary<CloseResponse>(scope, responseObserver) { in close()
DSecurity.kt116 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>()
DMap.kt38 override fun sendSMS(request: Empty, responseObserver: StreamObserver<Empty>) { in sendSMS()
39 grpcUnary<Empty>(scope, responseObserver) { in sendSMS()
DHid.kt51 responseObserver: StreamObserver<SendHostReportResponse>, in sendHostReport()
53 grpcUnary(scope, responseObserver) { in sendHostReport()
/packages/modules/Virtualization/android/TerminalApp/java/com/android/virtualization/terminal/
DDebianServiceImpl.kt45 responseObserver: StreamObserver<ReportVmActivePortsResponse?>, in reportVmActivePorts()
50 responseObserver.onNext(reply) in reportVmActivePorts()
51 responseObserver.onCompleted() in reportVmActivePorts()
56 responseObserver: StreamObserver<ForwardingRequestItem?>, in openForwardingRequestQueue()
70 runForwarderHost(request.cid, ForwarderHostCallback(responseObserver)) in openForwardingRequestQueue()
71 responseObserver.onCompleted() in openForwardingRequestQueue()
85 responseObserver: StreamObserver<ShutdownRequestItem?>, in openShutdownRequestQueue()
88 responseObserver as ServerCallStreamObserver<ShutdownRequestItem?> in openShutdownRequestQueue()
95 responseObserver.onNext(ShutdownRequestItem.newBuilder().build()) in openShutdownRequestQueue()
96 responseObserver.onCompleted() in openShutdownRequestQueue()
[all …]
/packages/apps/Dialer/java/com/android/voicemail/impl/
DVoicemailTranscriptionServiceGrpc.java122 ….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/
DDeviceCheckinClientImplTest.java966 StreamObserver<GetDeviceCheckinStatusResponse> responseObserver) { in makeSucceedingService()
973 responseObserver.onNext(response); in makeSucceedingService()
974 responseObserver.onCompleted(); in makeSucceedingService()
979 StreamObserver<IsDeviceInApprovedCountryResponse> responseObserver) { in makeSucceedingService() argument
983 responseObserver.onNext(response); in makeSucceedingService()
984 responseObserver.onCompleted(); in makeSucceedingService()
989 StreamObserver<PauseDeviceProvisioningResponse> responseObserver) { in makeSucceedingService() argument
993 responseObserver.onNext(response); in makeSucceedingService()
994 responseObserver.onCompleted(); in makeSucceedingService()
999 StreamObserver<ReportDeviceProvisionStateResponse> responseObserver) { in makeSucceedingService() argument
[all …]
/packages/modules/Bluetooth/framework/tests/bumble/src/android/bluetooth/
DLeAdvertisingTest.java74 StreamObserverSpliterator<ScanningResponse> responseObserver = in scanWithBumble() local
79 .scan(ScanRequest.newBuilder().build(), responseObserver); in scanWithBumble() local
80 Iterator<ScanningResponse> responseObserverIterator = responseObserver.iterator(); in scanWithBumble()

12