1 min readFeb 7, 2020
I think you can emulate DROP back pressure in a Flow by creating a `channelFlow` and use `offer` instead of `send`.
Something like this?:
fun <T> Flow<T>.drop() = channelFlow { collect { offer(it) } }
I think you can emulate DROP back pressure in a Flow by creating a `channelFlow` and use `offer` instead of `send`.
Something like this?:
fun <T> Flow<T>.drop() = channelFlow { collect { offer(it) } }
Associate Director of Product Engineering at @AccentureSong. You can find me online @streetsofboston or at https://www.linkedin.com/in/antonspaans/