Skip to content

Instantly share code, notes, and snippets.

@bijukunjummen

bijukunjummen/HandlingDownStreamErrors.kt

Created May 3, 2020 01: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 bijukunjummen/e8e9c4e609d2f77d1cc68dc0593d9d1c to your computer and use it in GitHub Desktop.
Save bijukunjummen/e8e9c4e609d2f77d1cc68dc0593d9d1c to your computer and use it in GitHub Desktop.
Download ZIP
Raw
HandlingDownStreamErrors.kt
.flatMap({ (message: String, deleteHandle: () -> Unit) ->
task(message)
.then(Mono.fromSupplier { Try.of { deleteHandle() } })
.doOnNext { t ->
t.onFailure { e -> LOGGER.error(e.message, e) }
}
.then()
.subscribeOn(taskScheduler)
}, concurrency)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment