Lock-free, MPSC-queue based, fast-path serializing Observer.
ObserveOn scheduled unsubscription
Add publishLast to RxScala
Add unsafeSubscribe to RxScala
Add unsubscribeOn to RxScala
Add share to RxScala
Add parallelMerge to RxScala
Add debounce variant to RxScala
Add toBlocking to RxScala and deprecate toBlockingObservable
Add timer variants to RxScala
Add amb variant to RxScala
Update CompletenessTest.scala
Add singleOption, singleOrElse, headOption, lastOption, lastOrElse to RxScala
Change 'window(closings: () => Observable[Any])' to 'window(boundary: => Observable[Any])'
Remove some javadoc errors; make others more pronounced ;-) (#1266)
Javadoc changes: 1) standardize opening sentences of function descriptions into the 3rd person descriptive; 2) add spurious @warn tag to throw compiler warnings indicating javadoc work TBD; 3) standardize on line-width; 4) document a few under-documented bits
Fix "window"; change "amb" parameter to varargs; add examples
Fix the bug that int overflow can bypass the range check
Operator Retry with predicate
ExecutorScheduler to wrap an Executor