Eugen Martynov
04/04/2018, 7:42 PMinline fun completable(
crossinline action: () -> Unit,
crossinline finally: () -> Unit = {}
): Completable {
return Completable.create { emitter ->
try {
action()
emitter.onComplete()
} catch (t: Throwable) {
emitter.tryOnError(t)
} finally {
finally()
}
}
}