withLocalLifecycle

fun <T> Flow<T>.withLocalLifecycle(minActiveState: Lifecycle.State = Lifecycle.State.STARTED): Flow<T>(source)