How to close Flux when client disconnected I want to implement log tailer over http, please see code snippet below: fun getFileUpdatesStream(fileName: String): Flux { var tailerToBeStopped: Tailer? = null return Flux.create { sink: FluxSink -> println("--------stream created--------") sink.next("\r\n")//Clear screen in browser val listener = object : TailerListenerAdapter() { override fun handle(line: String) { sink.next("$line\r\n")...