Skip to content

🛸A library to provide Future/Promise pattern API that is backed by RxSwift.

License

Notifications You must be signed in to change notification settings

FluidGroup/RxFuture

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

36 Commits
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

RxFuture

A temporary solution

What's this?

A library to provide Future/Promise pattern API that is backed by RxSwift.

Why do we need this against using Single?

Firstly, Future/Promise pattern fits to return a single result of an asynchronous task.

func doSomething() -> Future<E>

Future/Promise pattern can also do with API of RxSwift only. With using Observable or some PrimitiveSequence.

The problems in this case, First, Observable does not know how many it will be subscribed. So, Observable always should be shared sequence. If it isn't, a task wrapped by Observable will run by each of subscribe. Second, a task wrapped by Observable does not know when starts. It depends on subscribe.

The second case depends on RxSwift. Almost of Observables in RxSwift are cold-observable.

func doSomething() -> Observable<E>

the name of this function says "do something", but actually, "something" will not be done until subscribed.

A below name may be better than above.

func taskToDoSomething() -> Observable<E>

Basically, Future will run a wrapped task immediately. So, I created an object like as Future with RxSwift.

What's the differences with Single<E>?

RxFuture is different with Single. We can say RxFuture runs similar with Combine.Future.
RxFuture and Combine.Future runs their tasks immediately and they caches result until they are deallocated.

About

🛸A library to provide Future/Promise pattern API that is backed by RxSwift.

Topics

Resources

License

Stars

Watchers

Forks

Packages

No packages published