Florian Schuster
Florian Schuster
This would be a valid use-case in my opinion for `takeUntil`: ``` kotlin val cancelChannel: BroadCastChannel val intervalFlow: Flow // emits every x TimeUnit intervalFlow .takeUntil(cancelChannel.asFlow()) .onEach { /* do...
> @floschu Where you might encounter a use-case like this? You can use structured concurrency for this kind of cancellation. Can you elaborate on your example, please. If the intervalFlow...
> @floschu Your latest example is not reliable. You are, again, collecting the same `actions` flow twice. > > How to write it correctly? I don't have a ready answer....