<How to close Flux when client disconnected> I wan...

# stackoverflow

[user]

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")...