New operators: `concatEmptyWith` and `mergeEmptyWith`.#3060

Closed

NiteshKant wants to merge 83 commits intoReactiveX:1.xfrom

Commits on Jul 15, 2015

New operators: `concatEmptyWith` and `mergeEmptyWith`.
Nitesh Kant
committed

Commits on Oct 9, 2015

Revert "No need to allocate a new head node."

abersnaze
authored and
Nitesh Kant
committed
Revert "Operator replay() now supports backpressure"

abersnaze
authored and
Nitesh Kant
committed
Revert "If cache() now supports backpressure, correct javadocs to indicate this."

abersnaze
authored and
Nitesh Kant
committed
Revert "cache now supports backpressure"

abersnaze
authored and
Nitesh Kant
committed
Fix autoConnect calling onStart twice.

akarnokd
authored and
Nitesh Kant
committed
Private toObservable renamed to asObservable

benjchristensen
authored and
Nitesh Kant
committed
Single.toObservable

benjchristensen
authored and
Nitesh Kant
committed
1.0.13

benjchristensen
authored and
Nitesh Kant
committed
Fix request != 0 checking in the scalar paths of merge()

akarnokd
authored and
Nitesh Kant
committed
reduce probability of ExecutorSchedulerTest.testOnBackpressureDrop failing on slow machine

davidmoten
authored and
Nitesh Kant
committed
break tests as approach timeout so that don't fail on slow machines

davidmoten
authored and
Nitesh Kant
committed
Add "since" annotations to javadocs for new Experimental/Beta methods

DavidMGross
authored and
Nitesh Kant
committed
window() behavior changed, so did marble diagram & thus its size

DavidMGross
authored and
Nitesh Kant
committed
remove OperatorOnErrorFlatMap because unused

davidmoten
authored and
Nitesh Kant
committed
Unit tests and cleanup of JCTools' queues.

akarnokd
authored and
Nitesh Kant
committed
Fix take swallowing exception if thrown by the exactly the nth onNext

akarnokd
authored and
Nitesh Kant
committed
Test coverage of rx.functions utility methods.

akarnokd
authored and
Nitesh Kant
committed
cache() now supports backpressure (again)

akarnokd
authored and
Nitesh Kant
committed
Movet LinkedArrayListTest to the test section.

akarnokd
authored and
Nitesh Kant
committed
Operator replay() now supports backpressure (again)

akarnokd
authored and
Nitesh Kant
committed
No InterruptedException with synchronous BlockingObservable

ypresto
authored and
Nitesh Kant
committed
Improve performance of NewThreadWorker.tryEnableCancelPolicy().

artem-zinnatullin
authored and
Nitesh Kant
committed
Fix retry with predicate ignoring backpressure.

akarnokd
authored and
Nitesh Kant
committed
add backpressure to OperatorMaterialize

davidmoten
authored and
Nitesh Kant
committed
Add links to page that explains The Observable Contract

DavidMGross
authored and
Nitesh Kant
committed
Implemented Observable.x(ConversionFunc) to allow external extensions to Observables.

Aaron Tull
authored and
Nitesh Kant
committed
eliminate javadoc compiler warnings, add "since" stub

DavidMGross
authored and
Nitesh Kant
committed
Correct scheduler memory leak test for from(Executor) and added check

akarnokd
authored and
Nitesh Kant
committed
Fix for BackpressureUtils method javadoc

artem-zinnatullin
authored and
Nitesh Kant
committed
Remove redundant cast in Exceptions

artem-zinnatullin
authored and
Nitesh Kant
committed
Remove unnecessary static modifier

artem-zinnatullin
authored and
Nitesh Kant
committed
fix SynchronizedQueue.equals

davidmoten
authored and
Nitesh Kant
committed
Remove redundant type parameter in EmptyAction

jacek-rzrz
authored and
Nitesh Kant
committed
Test coverage for the observers package.

akarnokd
authored and
Nitesh Kant
committed
OperatorSwitch - fix lost requests race condition using ProducerArbiter

davidmoten
authored and
Nitesh Kant
committed
FromIterable overhead reduction.

akarnokd
authored and
Nitesh Kant
committed
Range overhead reduction

akarnokd
authored and
Nitesh Kant
committed
Remove redundant final modifier from static method in Actions

artem-zinnatullin
authored and
Nitesh Kant
committed
Version 1.0.14

stevegury
authored and
Nitesh Kant
committed
Update README.md

benjchristensen
authored and
Nitesh Kant
committed
catch onCompleted unsubscribe error and report to RxJavaPlugin error handler

davidmoten
authored and
Nitesh Kant
committed
BackpressureUtils capped add/multiply methods + tests

akarnokd
authored and
Nitesh Kant
committed
Fixed negative request due to unsubscription of a large requester

akarnokd
authored and
Nitesh Kant
committed
MapNotification producer NPE fix

akarnokd
authored and
Nitesh Kant
committed
Scan backpressure and first emission fix

akarnokd
authored and
Nitesh Kant
committed
Fix to Notification equals method.

wrightm
authored and
Nitesh Kant
committed
Refactored exception reporting of most operators.

akarnokd
authored and
Nitesh Kant
committed
Implementing the SyncOnSubscribe

Aaron Tull
authored and
Nitesh Kant
committed
Fixing concurrent unsubscribe case of SyncOnSubscribe

Aaron Tull
authored and
Nitesh Kant
committed
Add Observable.fromCallable() as a companion for Observable.defer()

artem-zinnatullin
authored and
Nitesh Kant
committed
test/subjects: Use statically imported never() methods

Turbo87
authored and
Nitesh Kant
committed
BehaviorSubjectTest: Fix verification in testCompletedAfterErrorIsNotSent3()

Turbo87
authored and
Nitesh Kant
committed
BehaviorSubjectTest: Simplify testUnsubscriptionCase() test

Turbo87
authored and
Nitesh Kant
committed
Implemented the AsyncOnSubscribe

Aaron Tull
authored and
Nitesh Kant
committed
Lint fixes for unnecessary unboxing.

Kevin Coughlin
authored and
Nitesh Kant
committed
Use ternary for comparison in place of Long.compareTo for Java 6 support.

Kevin Coughlin
authored and
Nitesh Kant
committed
Remove unused field updater from SubjectSubscriptionManager

artem-zinnatullin
authored and
Nitesh Kant
committed
Fix typo in a comment inside Observable.subscribe

stevegury
authored and
Nitesh Kant
committed
Make field final and remove unnecessary unboxing in OnSubscribeRedo.RetryWithPredicate

artem-zinnatullin
authored and
Nitesh Kant
committed
Fix synchronization on non-final field in BufferUntilSubscriber

artem-zinnatullin
authored and
Nitesh Kant
committed
Fix to a bunch of bugs and issues with AsyncOnSubscribe

akarnokd
authored and
Nitesh Kant
committed
Fix for take() reentrancy bug.

akarnokd
authored and
Nitesh Kant
committed
Schedulers shutdown capability.

akarnokd
authored and
Nitesh Kant
committed
Hiding start(), moved test to compensate.

akarnokd
authored and
Nitesh Kant
committed
pull back the Experimental/Beta of the changes until 1.1.x (+1 squashed commit)

akarnokd
authored and
Nitesh Kant
committed
Added warning to `Observable.doOnRequest` javadoc.

Aaron Tull
authored and
Nitesh Kant
committed
DoOnEach: report both original exception and callback exception.

akarnokd
authored and
Nitesh Kant
committed
Remove unused private method from CachedObservable and make "state" final

artem-zinnatullin
authored and
Nitesh Kant
committed
Safer error handling in BlockingOperatorToFuture

artem-zinnatullin
authored and
Nitesh Kant
committed
Remove unnecessary onStart in OperatorGroupBy

Kevin Coughlin
authored and
Nitesh Kant
committed
Eager concatMap

akarnokd
authored and
Nitesh Kant
committed
Make BlockingOperatorToIterator exert backpressure.

vqvu
authored and
Nitesh Kant
committed
Request data in batches.

vqvu
authored and
Nitesh Kant
committed
BlockingObservable + subscribe methods.

akarnokd
authored and
Nitesh Kant
committed
Update README.md

abersnaze
authored and
Nitesh Kant
committed
Renaming Observable#x to Observable#extend

Aaron Tull
authored and
Nitesh Kant
committed
Add Single.doOnError()

artem-zinnatullin
authored and
Nitesh Kant
committed
Add Single.fromCallable()

artem-zinnatullin
authored and
Nitesh Kant
committed
New operators: `concatEmptyWith` and `mergeEmptyWith`.
Nitesh Kant
committed
Add Single.doOnSuccess()

artem-zinnatullin
authored and
Nitesh Kant
committed
Merge branch '1.x' of https://github.com/Netflix/RxJava into 1.x
Nitesh Kant
committed
Merge branch '1.x' of https://github.com/NiteshKant/RxJava into 1.x
Nitesh Kant
committed