(crossposting here as well)

# coroutines

[parth]

(crossposting here as well)

[marstran]

I don't think there is such a function in kotlinx.coroutines, but it shouldn't be too hard to implement yourself.

[marstran]

This seems to work, although there might exist a simpler implementation:

fun <T> Flow<T>.skipUntil(flow: Flow<*>): Flow<T> = channelFlow {
    val isSkipping = MutableStateFlow(true)    
    launch { 
    	collect { if (!isSkipping.value) send(it)  }
    }
    
    val signal = flow.first()
    isSkipping.value = false
}

[parth]

ah yup, that makes sense as an impl

[parth]

thank you!

[flosch]

there is actually a discussion on github about such operators:
https://github.com/Kotlin/kotlinx.coroutines/issues/1850

[parth]

ah, i was searching for skipUntil, that’s why the issue didn’t show up for me. Thanks!