Extensions for io.reactivex.CompletableSource

await

suspend fun CompletableSource.await(): Unit

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