Merge pull request ReactiveX#2912 from akarnokd/FixEventLoopsPerfDegr…

…adation

Fix the performance degradation due to different schedule execution and

Merge pull request ReactiveX#2866 from davidmoten/Action1-argument-name

Use simpler naming in Action1, Func1 to assist IDEs

Merge pull request ReactiveX#2809 from akarnokd/TakeUntilTerminationFix

Fixed takeUntil not unsubscribing from either of the observables in case

Merge pull request ReactiveX#2760 from akarnokd/WithLatestFrom

Operator: WithLatestFrom

Merge pull request ReactiveX#2627 from akarnokd/FlatMapMaxConcurrent

FlatMap overloads with maximum concurrency parameter

Secure Variables for Release

Release of 1.0.4

- 7da6110: Merge pull request ReactiveX#2237 from benjchristensen/publish-ring-buffer-usage
- e39599c: Make Publish Operator Release RingBuffer
- 4a08644: Merge pull request ReactiveX#2052 from davidmoten/make-class-static
- 2f821d8: Merge pull request ReactiveX#2156 from zsxwing/map-swallow-fatal-exceptions
- a683fcc: enable faster travis builds
- 3563021: Fix the issue that map may swallow fatal exceptions
- 9cae739: Merge pull request ReactiveX#2053 from akarnokd/ReplaySubjectBoundedFix1218
- 1a068dd: Fixed wrong subject use in test.
- 093bbeb: OperatorDoOnRequest.ParentSubscriber should be static class
- 7c408f4: Merge pull request ReactiveX#1967 from zsxwing/fix-groupby-unsubscribe
- 5c0be52: Version 1.0.3
- 31281b6: Update as per review
- 83fc06f: Add a new state of `terminated` to fix the race condition of `errorEmitted`; Add more comments.
- 272a752: Propagate onError to all groups
- 8026b41: Fix the issue that GroupBy may not call 'unsubscribe'

Release of 1.0.3

- 0f2e883: Merge pull request ReactiveX#1973 from akarnokd/ReplaySubjectFix1215
- da987ed: javadocs: minor style, grammar changes; add @SInCE annotation to new method
- c148ea5: Fixed test issuing non-serialized messages to the subject.
- 1d487a3: Merge pull request ReactiveX#1965 from zsxwing/fix-sample-unsubscribe
- 29e764a: Merge pull request ReactiveX#1966 from zsxwing/fix-groupby-null-key
- f1b9253: Merge pull request ReactiveX#1964 from zsxwing/fix-buffer-request
- 73715bf: Merge pull request ReactiveX#1957 from zsxwing/fix-scan
- ba85468: Merge pull request ReactiveX#1950 from zsxwing/unsubscribed
- 162e042: Merge pull request ReactiveX#1938 from akarnokd/OperatorAnyFix
- e4239b5: Merge pull request ReactiveX#1968 from ReactiveX/bump-to-2.2
- 8359f03: Merge pull request ReactiveX#1961 from benjchristensen/issue-1941-remove-request-batching
- 09ae28b: Apply java plugin
- 39c7856: Bump to 2.2
- 4c14177: add @SInCE section to doOnRequest() javadocs
- 522ce79: Fix the issue that Sample doesn't call 'unsubscribe'
- d5b4d6f: Fix NPE when the key is null in GroupBy
- 0c135fd: Handle 0 or negative request in Buffer
- 162c31c: Remove Request Batching in Merge
- dd73c15: Merge pull request ReactiveX#1960 from benjchristensen/doOnRequest
- 35f2807: SerialSubscription and MultipleAssignmentSubscription should use Subscriptions.empty()
- 237a728: doOnRequest
- 99155c0: Merge pull request ReactiveX#1953 from akarnokd/OperatorSerializePerfFix
- 7b25665: Merge pull request ReactiveX#1952 from zsxwing/remove-action-subscription
- 1b39e6b: Merge pull request ReactiveX#1951 from abersnaze/unnecessary
- f934706: Merge pull request ReactiveX#1947 from akarnokd/ReplaySubjectFirstEmissionFix
- 29c1b6e: Fix 'request(0)' issue in Scan
- aeea978: Fixed timer cast-to-int crash causing incorrect benchmark.
- 7337bb8: Remove ActionSubscription
- 332b67c: Remove extraneous request(n) and onCompleted() calls when unsubscribed.
- 4c16adf: Add "Subscriptions.unsubscribed" to fix the 'isUnsubscribed' issue
- b02e572: tidying up AbstractOnSubscribe javadocs
- f031b17: Merge pull request ReactiveX#1946 from akarnokd/AbstractOnSubscribe2
- b21aef9: minor tweaks to javadocs for new onBackpressureBuffer variants
- 053cc4f: Fixed first emission racing with pre and post subscription.
- 50563ce: AbstractOnSubscribe to help build Observables one onNext at a time.
- ea3732d: Merge pull request ReactiveX#1937 from akarnokd/SchedulerTestsFix
- d1908c5: Merge pull request ReactiveX#1928 from srvaroa/1.x
- 5b736f6: Merge pull request ReactiveX#1926 from zsxwing/fix-merge-finally
- 6620a14: Merge pull request ReactiveX#1922 from akarnokd/SchedulersRemoveOnCancelPolicy
- a40a659: Fixed OperatorAll unsubscribing downstream.
- ea26109: Any should not unsubscribe downstream.
- 5620449: Scheduler.Worker to be finally unsubscribed to avoid interference.
- 1d15fea: Add onBackpressureBuffer with capacity
- 54d4224: Move the codes out of the finally block
- 57156e3: javadoc: diagrams for onBackpressureBlock (would benefit from a review)
- 87ea431: Fixed wrong Java 8 reflection API call
- 4188f58: Set removeOnCancelPolicy on the threadpool if supported
- 294a8e8: Update CHANGES.md
- 00ca294: Update CHANGES.md
- 56be408: 1.0.2

Release of 1.0.2

- Merge pull request ReactiveX#1918 from ReactiveX/revert-1916-experimentalOnBackpressureBufferWithCapacity
- Revert "Experimental onBackpressureBufferWithCapacity"
- Merge pull request ReactiveX#1916 from benjchristensen/experimentalOnBackpressureBufferWithCapacity
- rx.internal.* warning
- BufferOverflowException -> MissingBackpressureException
- javadocs: add "since" reminder; minor text changes
- Mark onBackpressureBuffer(count) as Beta
- Use Action instead of Func0<Void>
- Merge branch '1.x' of github.com:srvaroa/RxJava into experimentalOnBackpressureBufferWithCapacity
- Merge pull request ReactiveX#1907 from benjchristensen/onBackpressureBlock
- Merge pull request ReactiveX#1912 from akarnokd/RetryWithBackpressureFix
- Merge pull request ReactiveX#1911 from akarnokd/AtomicPerf
- Fixed retry without backpressure & test function to support bp.
- getAndSet benchmarks
- Atomic operations JMH benchmarks
- Marking OnBackpressureBlock as @experimental
- Merge branch 'OnBackpressureBlock' of github.com:akarnokd/RxJava into onBackpressureBlock
- Merge pull request ReactiveX#1905 from benjchristensen/lifecycle-annotations
- Merge pull request ReactiveX#1904 from zsxwing/fix-scan
- Beta & Experimental Annotations
- Version and Lifecycle Annotations
- Merge pull request ReactiveX#1898 from akarnokd/ScheduledActionNoInterrupt
- Fix the bug that Scan may request 0 when n is 1
- Merge pull request ReactiveX#1903 from benjchristensen/testscheduler-1790
- Version 1.0.1
- Fix TestScheduler Handling of Immediate vs Virtual Time
- Fixed typo.
- Do not leave drain if queue has data and downstream doesn't do backpressure.
- Fixed accidental import * expansion.
- Operator OnBackpressureBlock
- Add optional bound to onBackpressureBuffer
- Some class simplifications.
- Perf profile & simplifications.
- Simplified the memory footprint.
- Cleanup the worker.
- Avoid self-interrupting of a completing ScheduledAction.

Release of 1.0.1

- Merge pull request ReactiveX#1901 from akarnokd/RedoRequestFix
- Restore timeout on the test.
- Fixed redo & groupBy backpressure management
- Merge pull request ReactiveX#1893 from akarnokd/MergeDelayErrorFix
- Avoid request(0) to trigger a recursive call.
- The backpressure exception might cut ahead of all onNext events.
- Fixed incorrect error merging.
- Version 1.0.0