Extensions for rx.Completable

awaitCompleted

suspend fun Completable.awaitCompleted(): Unit

Awaits for completion of this completable without blocking a thread. Returns Unit or throws the corresponding exception if this completable had produced error.