aries / net.globalid.aries.utils / toCompletable

toCompletable

inline fun <T> toCompletable(crossinline future: () -> CompletableFuture<T>): Completable

Returns a Completable instance future will be executed on back-thread and when subscriber subscribes to rx flow

Parameters

future - the future to react to

Return
the new Completable instance