Merge "PandoraServer: Properly cancel the job" (e65f667e) · Commits · e / os / android_packages_modules_Bluetooth

android/pandora/server/src/com/android/pandora/Utils.kt

+3 −0

Original line number	Diff line number	Diff line
		@@ -167,6 +167,7 @@ fun <T, U> grpcBidirectionalStream(
		): StreamObserver<T> {

		val inputChannel = Channel<T>()
		val serverCallStreamObserver = responseObserver as ServerCallStreamObserver<T>

		val job =
		scope.launch {
		@@ -184,6 +185,8 @@ fun <T, U> grpcBidirectionalStream(
		.launchIn(this)
		}

		serverCallStreamObserver.setOnCancelHandler { job.cancel() }

		return object : StreamObserver<T> {
		override fun onNext(req: T) {
		// Note: this should be made a blocking call, and the handler should run in a separate thread