Colton Nohelty

Probably the biggest blocker in this case is that state can be accidentally modified simultaneously by separate concurrent threads. Each platform will require separate implementations.

Document usage in the wiki and put some simple examples in the README

4

Title explains itself. The goal is to make the library more accessible. Ideally, the wiki would cover each source type and the operators.

The delay operator will likely need to have multiple platform dependent implementations. Delay should shift emissions and the complete notification by the specified amount of time (`timeshiftInMillis: Long`). An error...

Regression/integration tests covering the Source's doOnError and doOnComplete methods including making sure that the operator itself always properly disposes the upstream and removes observers from the emitter when the created...