Implement a cached thread scheduler using event loops
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])'
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
Add "buffer(=> Observable[Any])" to replace "buffer(() => Observable[Any])" and "buffer(Observable[Any])""; Remove the cast for "window(=> Observable[Any])"