Skip to content

Instantly share code, notes, and snippets.

@oogatta

oogatta/kotlin-flow-retrying-forever-suspending-functions.kt

Last active September 14, 2020 16:21
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save oogatta/0e43b13c1adcd14b720d73a27e8e7b16 to your computer and use it in GitHub Desktop.
Save oogatta/0e43b13c1adcd14b720d73a27e8e7b16 to your computer and use it in GitHub Desktop.
Download ZIP
kotlin flow retrying forever (suspending functions)
Raw
kotlin-flow-retrying-forever-suspending-functions.kt
// suspending functions
flow {
emit(doSomethingSuspending())
}.mapNotNull {
if (it == null) {
throw Exception()
}
it
}.retryWhen { _, _ ->
delay(RETRY_INTERVAL)
true
}.collect { // or .single()
// do something
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment