fun start()

in plugin-bazel-event-service/src/main/kotlin/bazel/BinaryFileEventStream.kt [44:51]

• 8 lines of code
• 2 McCabe index (conditional complexity)

        fun start(onEvent: (Result) -> Unit): AutoCloseable {
            val thread = thread(name = "BazelEventStream") { readBazelStreamLoop(onEvent) }
            return AutoCloseable {
                if (disposed.compareAndSet(false, true)) {
                    thread.join()
                }
            }
        }