takeUntilSignal

fun <T> Flow<T>.takeUntilSignal(signal: Flow<Unit?>): Flow<T>