Closed pakoito closed 8 years ago
Using Observable.create() requires respecting several principles about unsubscription and backpressure that this library is not respecting. Apply these principles instead:
https://www.reddit.com/r/androiddev/comments/3u5w0c/if_you_are_writing_observablecreate_theres_a_big/
Thanks for your feedback! I'm going to start implement this.
Fixed on 0.2
Using Observable.create() requires respecting several principles about unsubscription and backpressure that this library is not respecting. Apply these principles instead:
https://www.reddit.com/r/androiddev/comments/3u5w0c/if_you_are_writing_observablecreate_theres_a_big/