aries / net.globalid.aries.utils / toSingle

toSingle

inline fun <T> toSingle(crossinline future: () -> CompletableFuture<T>): Single<T>

Returns a Single 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 Single instance