Sensor Flow with lifecycleScope

MainActivity.kt

@ExperimentalCoroutinesApi
class MainActivity : AppCompatActivity() {
    private var working = false
    private var job: Job? = null

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_main)

        val button = findViewById<Button>(R.id.button)

        button.setOnClickListener {
            button.isEnabled = false

            working = !working

            if (working) {
                button.text = "stop"
                start()
            } else {
                stop()
                button.text = "run"
            }

            button.isEnabled = true
        }
    }

    private fun start() {
        job = lifecycleScope.launch {
            accelerometerFlow(this@MainActivity)
                .collect {
                    Log.d("MainActivity", "$it")
                }
        }
    }

    private fun stop() {
        job?.cancel()
    }
}

@ExperimentalCoroutinesApi
fun accelerometerFlow(context: Context) = channelFlow {
    val handlerThread = HandlerThread("test", Process.THREAD_PRIORITY_BACKGROUND).apply { start() }
    val handler = Handler(handlerThread.looper)

    val sensorManager = context.getSystemService(Context.SENSOR_SERVICE) as SensorManager

    val sensorEventListener = object : SensorEventListener {
        override fun onSensorChanged(event: SensorEvent?) {
            Log.v("accelerometerFlow", "$event")
            CoroutineScope(coroutineContext).launch {
                send(event?.values?.toList())
            }
        }

        override fun onAccuracyChanged(sensor: Sensor?, accuracy: Int) {}
    }

    val sensor = sensorManager.getDefaultSensor(Sensor.TYPE_LINEAR_ACCELERATION)

    sensorManager.registerListener(sensorEventListener, sensor, SensorManager.SENSOR_DELAY_NORMAL, handler)

    awaitClose {
        sensorManager.unregisterListener(sensorEventListener, sensor)
        handlerThread.quitSafely()
    }
}