collectAsync

fun <T> Flow<T>.collectAsync(handler: (T) -> Unit): CancellationToken