Flux onBackpressureDrop and coroutines collect extension does not called passed lambda

[denyshorman]

Simple code with coroutines and project reactor does not produce any values:

Expected: "test" printed
Actual: don't see any output on the console

Kotlin coroutines version: 1.2.1

import kotlinx.coroutines.reactive.collect
import kotlinx.coroutines.runBlocking
import reactor.core.publisher.Flux

fun main(args: Array<String>) {
    runBlocking {
        Flux.never<Long>()
            .startWith(0)
            .onBackpressureDrop()
            .collect {
                println("test")
            }
    }
}

[elizarov]

Good catch. Thanks for the report.