Files

 1ea1e2a

/

observable

/

Copy path

Directory actions

More options

Directory actions

More options

Latest commit

akarnokd

2.x: Cleanup Observable.flatMap drain logic (#6232)

Sep 30, 2018

1ea1e2a · Sep 30, 2018

History

History

/

observable

/

Top

Folders and files

Name		Name	Last commit message	Last commit date
parent directory ..
AbstractObservableWithUpstream.java		AbstractObservableWithUpstream.java	Update Copyright to 'RxJava Contributors' (#4980)	Jan 9, 2017
BlockingObservableIterable.java		BlockingObservableIterable.java	2.x: Cleanup multiple empty lines in sources (#6182)	Aug 28, 2018
BlockingObservableLatest.java		BlockingObservableLatest.java	2.x: option to fail for using blockingX on the computation scheduler (#…	Jan 27, 2017
BlockingObservableMostRecent.java		BlockingObservableMostRecent.java	2.x: Cleanup multiple empty lines in sources (#6182)	Aug 28, 2018
BlockingObservableNext.java		BlockingObservableNext.java	Correct marble diagram dimensions (#5087)	Feb 9, 2017
ObservableAll.java		ObservableAll.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableAllSingle.java		ObservableAllSingle.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableAmb.java		ObservableAmb.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableAny.java		ObservableAny.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableAnySingle.java		ObservableAnySingle.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableAutoConnect.java		ObservableAutoConnect.java	Update Copyright to 'RxJava Contributors' (#4980)	Jan 9, 2017
ObservableBlockingSubscribe.java		ObservableBlockingSubscribe.java	2.x: cleanup for text and javadoc 04/15 (#5286)	Apr 15, 2017
ObservableBuffer.java		ObservableBuffer.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableBufferBoundary.java		ObservableBufferBoundary.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableBufferBoundarySupplier.java		ObservableBufferBoundarySupplier.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableBufferExactBoundary.java		ObservableBufferExactBoundary.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableBufferTimed.java		ObservableBufferTimed.java	2.x: Cleanup multiple empty lines in sources (#6182)	Aug 28, 2018
ObservableCache.java		ObservableCache.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableCollect.java		ObservableCollect.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableCollectSingle.java		ObservableCollectSingle.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableCombineLatest.java		ObservableCombineLatest.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableConcatMap.java		ObservableConcatMap.java	2.x: Cleanup multiple empty lines in sources (#6182)	Aug 28, 2018
ObservableConcatMapEager.java		ObservableConcatMapEager.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableConcatWithCompletable.java		ObservableConcatWithCompletable.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableConcatWithMaybe.java		ObservableConcatWithMaybe.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableConcatWithSingle.java		ObservableConcatWithSingle.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableCount.java		ObservableCount.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableCountSingle.java		ObservableCountSingle.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableCreate.java		ObservableCreate.java	2.x: Cleanup multiple empty lines in sources (#6182)	Aug 28, 2018
ObservableDebounce.java		ObservableDebounce.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableDebounceTimed.java		ObservableDebounceTimed.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableDefer.java		ObservableDefer.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableDelay.java		ObservableDelay.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableDelaySubscriptionOther.java		ObservableDelaySubscriptionOther.java	2.x: fix private field access, few generics problems (#5176)	Mar 11, 2017
ObservableDematerialize.java		ObservableDematerialize.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableDetach.java		ObservableDetach.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableDistinct.java		ObservableDistinct.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableDistinctUntilChanged.java		ObservableDistinctUntilChanged.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableDoAfterNext.java		ObservableDoAfterNext.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableDoFinally.java		ObservableDoFinally.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableDoOnEach.java		ObservableDoOnEach.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableDoOnLifecycle.java		ObservableDoOnLifecycle.java	Update Copyright to 'RxJava Contributors' (#4980)	Jan 9, 2017
ObservableElementAt.java		ObservableElementAt.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableElementAtMaybe.java		ObservableElementAtMaybe.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableElementAtSingle.java		ObservableElementAtSingle.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableEmpty.java		ObservableEmpty.java	Update Copyright to 'RxJava Contributors' (#4980)	Jan 9, 2017
ObservableError.java		ObservableError.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableFilter.java		ObservableFilter.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableFlatMap.java		ObservableFlatMap.java	2.x: Cleanup Observable.flatMap drain logic (#6232)	Sep 30, 2018
ObservableFlatMapCompletable.java		ObservableFlatMapCompletable.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableFlatMapCompletableCompletable.java		ObservableFlatMapCompletableCompletable.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableFlatMapMaybe.java		ObservableFlatMapMaybe.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableFlatMapSingle.java		ObservableFlatMapSingle.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableFlattenIterable.java		ObservableFlattenIterable.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableFromArray.java		ObservableFromArray.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableFromCallable.java		ObservableFromCallable.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableFromFuture.java		ObservableFromFuture.java	2.x: Test cleanup (#6119)	Aug 1, 2018
ObservableFromIterable.java		ObservableFromIterable.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableFromPublisher.java		ObservableFromPublisher.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableFromUnsafeSource.java		ObservableFromUnsafeSource.java	Update Copyright to 'RxJava Contributors' (#4980)	Jan 9, 2017
ObservableGenerate.java		ObservableGenerate.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableGroupBy.java		ObservableGroupBy.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableGroupJoin.java		ObservableGroupJoin.java	2.x: Cleanup multiple empty lines in sources (#6182)	Aug 28, 2018
ObservableHide.java		ObservableHide.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableIgnoreElements.java		ObservableIgnoreElements.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableIgnoreElementsCompletable.java		ObservableIgnoreElementsCompletable.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableInternalHelper.java		ObservableInternalHelper.java	2.x: Cleanup multiple empty lines in sources (#6182)	Aug 28, 2018
ObservableInterval.java		ObservableInterval.java	2.x: Cleanup multiple empty lines in sources (#6182)	Aug 28, 2018
ObservableIntervalRange.java		ObservableIntervalRange.java	2.x: Cleanup multiple empty lines in sources (#6182)	Aug 28, 2018
ObservableJoin.java		ObservableJoin.java	2.x: Cleanup multiple empty lines in sources (#6182)	Aug 28, 2018
ObservableJust.java		ObservableJust.java	2.x: Test cleanup (#6119)	Aug 1, 2018
ObservableLastMaybe.java		ObservableLastMaybe.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableLastSingle.java		ObservableLastSingle.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableLift.java		ObservableLift.java	2.x: Test cleanup (#6119)	Aug 1, 2018
ObservableMap.java		ObservableMap.java	2.x: Cleanup multiple empty lines in sources (#6182)	Aug 28, 2018
ObservableMapNotification.java		ObservableMapNotification.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableMaterialize.java		ObservableMaterialize.java	2.x: Cleanup multiple empty lines in sources (#6182)	Aug 28, 2018
ObservableMergeWithCompletable.java		ObservableMergeWithCompletable.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableMergeWithMaybe.java		ObservableMergeWithMaybe.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableMergeWithSingle.java		ObservableMergeWithSingle.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableNever.java		ObservableNever.java	Update Copyright to 'RxJava Contributors' (#4980)	Jan 9, 2017
ObservableObserveOn.java		ObservableObserveOn.java	2.x: Make observeOn not let worker.dispose() called prematurely (#6167)	Aug 22, 2018
ObservableOnErrorNext.java		ObservableOnErrorNext.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableOnErrorReturn.java		ObservableOnErrorReturn.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservablePublish.java		ObservablePublish.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservablePublishSelector.java		ObservablePublishSelector.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableRange.java		ObservableRange.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableRangeLong.java		ObservableRangeLong.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableReduceMaybe.java		ObservableReduceMaybe.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableReduceSeedSingle.java		ObservableReduceSeedSingle.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableReduceWithSingle.java		ObservableReduceWithSingle.java	Update Copyright to 'RxJava Contributors' (#4980)	Jan 9, 2017
ObservableRefCount.java		ObservableRefCount.java	2.x: Fix refCount termination-reconnect race (#6187)	Aug 30, 2018
ObservableRepeat.java		ObservableRepeat.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableRepeatUntil.java		ObservableRepeatUntil.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableRepeatWhen.java		ObservableRepeatWhen.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableReplay.java		ObservableReplay.java	2.x: Fix refCount termination-reconnect race (#6187)	Aug 30, 2018
ObservableRetryBiPredicate.java		ObservableRetryBiPredicate.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableRetryPredicate.java		ObservableRetryPredicate.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableRetryWhen.java		ObservableRetryWhen.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableSampleTimed.java		ObservableSampleTimed.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableSampleWithObservable.java		ObservableSampleWithObservable.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableScalarXMap.java		ObservableScalarXMap.java	2.x: Test cleanup (#6119)	Aug 1, 2018
ObservableScan.java		ObservableScan.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableScanSeed.java		ObservableScanSeed.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableSequenceEqual.java		ObservableSequenceEqual.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableSequenceEqualSingle.java		ObservableSequenceEqualSingle.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableSerialized.java		ObservableSerialized.java	Update Copyright to 'RxJava Contributors' (#4980)	Jan 9, 2017
ObservableSingleMaybe.java		ObservableSingleMaybe.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableSingleSingle.java		ObservableSingleSingle.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableSkip.java		ObservableSkip.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableSkipLast.java		ObservableSkipLast.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableSkipLastTimed.java		ObservableSkipLastTimed.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableSkipUntil.java		ObservableSkipUntil.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableSkipWhile.java		ObservableSkipWhile.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableSubscribeOn.java		ObservableSubscribeOn.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableSwitchIfEmpty.java		ObservableSwitchIfEmpty.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableSwitchMap.java		ObservableSwitchMap.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableTake.java		ObservableTake.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableTakeLast.java		ObservableTakeLast.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableTakeLastOne.java		ObservableTakeLastOne.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableTakeLastTimed.java		ObservableTakeLastTimed.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableTakeUntil.java		ObservableTakeUntil.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableTakeUntilPredicate.java		ObservableTakeUntilPredicate.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableTakeWhile.java		ObservableTakeWhile.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableThrottleFirstTimed.java		ObservableThrottleFirstTimed.java	2.x: Cleanup multiple empty lines in sources (#6182)	Aug 28, 2018
ObservableThrottleLatest.java		ObservableThrottleLatest.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableTimeInterval.java		ObservableTimeInterval.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableTimeout.java		ObservableTimeout.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableTimeoutTimed.java		ObservableTimeoutTimed.java	2.x: Cleanup multiple empty lines in sources (#6182)	Aug 28, 2018
ObservableTimer.java		ObservableTimer.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableToList.java		ObservableToList.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableToListSingle.java		ObservableToListSingle.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableUnsubscribeOn.java		ObservableUnsubscribeOn.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableUsing.java		ObservableUsing.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableWindow.java		ObservableWindow.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableWindowBoundary.java		ObservableWindowBoundary.java	2.x: Fix window(Observable|Callable) upstream handling (#5887)	Mar 4, 2018
ObservableWindowBoundarySelector.java		ObservableWindowBoundarySelector.java	2.x: Cleanup multiple empty lines in sources (#6182)	Aug 28, 2018
ObservableWindowBoundarySupplier.java		ObservableWindowBoundarySupplier.java	2.x: Fix window(Observable|Callable) upstream handling (#5887)	Mar 4, 2018
ObservableWindowTimed.java		ObservableWindowTimed.java	2.x: Cleanup multiple empty lines in sources (#6182)	Aug 28, 2018
ObservableWithLatestFrom.java		ObservableWithLatestFrom.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableWithLatestFromMany.java		ObservableWithLatestFromMany.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
ObservableZip.java		ObservableZip.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObservableZipIterable.java		ObservableZipIterable.java	2.x: cleanup newline separation, some field namings (#6150)	Aug 9, 2018
ObserverResourceWrapper.java		ObserverResourceWrapper.java	2.x: Cleaunp - rename fields to upstream and downstream (#6129)	Aug 5, 2018
View all files