basically, it's a timeout for flow, it closes after timedOut

# coroutines

[myanmarking]

basically, it's a timeout for flow, it closes after timedOut

[streetsofboston]

Would something like this work?

fun <T> Flow<T>.timeout(millis: Long) = flow {
    [e-mail] {
        withTimeout(millis) {
            emit(it)
        }
    }
}

[myanmarking]

hm, the timeout would be to the overall emissions, not on each one. i managed to get this solution. what do you think?

[myanmarking]

fun <T> Flow<T>.timeout(durationInMillis: Long): Flow<T> =
    flow {
        coroutineScope {
            val outerScope = this
            launch {
                try {
                    delay(durationInMillis)
                    outerScope.cancel()
                } catch (e: CancellationException) {
                    outerScope.cancel(e) // cancel outer scope on cancellation exception, too
                }
            }
            collect { emit(it) }
        }
    }

[myanmarking]

oh wait, cannot be like this

[myanmarking]

yes, it works. gona write some tests for it

[Dominaezzz]

fun <T> Flow<T>.timeout(millis: Long) = flow {
    withTimeout(millis) {
        [e-mail] {
            emit(it)
        }
    }
}

[myanmarking]

even better solution. thanks!