2.0 progress on operators #3210
Labels
Milestone
Comments
|
Operators I'm not going to implement:
Edit
|
|
I understand join and groupJoin, but what is your reason for dismissing the others?
|
|
I don't feel the need to implement them but anybody else is welcome to do them. |
|
All operators that I planned to implement are now implemented. Closing. |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
This page tracks which operators have been implemented in the 2.x branch. New overloads and new operators proposed for 1.x or 2.x are not included.
ambOperator amb, ambWith #3235combineLatestOperator combineLatest #3241concatcreatedeferemptyerrorfrom(iterable, array)from(plain future, i.e., notCompletableFuture)intervaljust(single)just(2-9 operands)I suggest deprecation/not implementing -> fromArray insteadOperator scan, reduce. Fixes to TestSubscriber async behavior. #3255 (to many tests depend on this, I don't want to change them all)mergemergeDelayErrorneverrange(unscheduled)rangeOperations doOnX. #3225 (scheduled) I suggest deprecation/not implementing it -> use compositionsequenceEqualOperator sequenceEqual #3240switchOnNextOperator switchMap, switchOnNext, added missing merge and concat #3234timer(once)implemented under the name interval(long, TimeUnit), may need name changeFixes to classes, convenience operators mostly. #3223usingOperator using, some internal refactorings. #3242zipOperator zip plus Function3..Function9. #3215Instance methods
allautoConnect(onConnectableObservable)ambWithOperator amb, ambWith #3235asObservablebufferOperators buffer: size, time, size + time #3248 Operator buffer with boundary and open-close, fixes to the timed #3250cachecastFixes to classes, convenience operators mostly. #3223collectOperator collect, toMap and toMultimap based on it. #3226composeconcatMapconcatWithcontainsFixes to classes, convenience operators mostly. #3223countI suggest having only a single, long countercountLongunder the name countdebounceOperator debounce (time, selector), throttleWithTimeout (alias) #3254defaultIfEmptyOperato switchIfEmpty, defaultIfEmpty #3230delayOperators delay, delaySubscription, share. #3244delaySubscriptionOperators delay, delaySubscription, share. #3244dematerializeOperator materialize, dematerialize, minor notification fix. #3243distinctOperator distinct, timeInterval, common Timed container. #3224distinctUntilChangedOperator distinct, timeInterval, common Timed container. #3224doOnCompletedOperations doOnX. #3225doOnEachOperations doOnX. #3225doOnErrorOperations doOnX. #3225doOnNextOperations doOnX. #3225doOnRequestdoOnSubscribedoOnTerminateOperations doOnX. #3225doOnUnsubscribeelementAtexistsFixes to classes, convenience operators mostly. #3223filterfinallyDoOperations doOnX. #3225first(no predicate) Operators first, last, multi-offer for SpscLinkedArrayQueue #3232first(with predicate) Operators first, last, multi-offer for SpscLinkedArrayQueue #3232 I suggest deprecating/not implementing this overloadfirstOrDefaultOperators first, last, multi-offer for SpscLinkedArrayQueue #3232 as an overload to first.flatMap(minus the paired version)flatMap(paired version) Fixes to classes, convenience operators mostly. #3223flatMap(where onError and onCompleted is also mapped to an Observable) I suggest dropping thisflatMapIterableFixes to classes, convenience operators mostly. #3223 I'll come back to this if this can be implemented in a more efficient fashionforEach(single consumer only)forEach(with error and completion callback) I suggest deprecating/not implementing this overloadgroupByOperator groupBy #3212groupJoinI suggest deprecating/not implementing this operatorignoreElementsisEmptyjoinI suggest deprecating/not implementing this operatorlastOperators first, last, multi-offer for SpscLinkedArrayQueue #3232 I suggest dropping the predicate versionlastOrDefaultOperators first, last, multi-offer for SpscLinkedArrayQueue #3232 I suggest dropping the predicate version and having this as an overload under the name lastliftlimitFixes to classes, convenience operators mostly. #3223 I suggest dropping this and stick with takemapmaterializeOperator materialize, dematerialize, minor notification fix. #3243mergeWithnestOperator distinct, timeInterval, common Timed container. #3224 I suggest dropping thisobserveOnofTypeFixes to classes, convenience operators mostly. #3223onBackpressureBlockthis is already deprecated and I suggest dropping itonBackpressureBuffer(without action)onBackpressureBuffer(with action) Operator timeout, onBackpressureBuffer(onOverflow), fixes to parameter #3257onBackpressureDroponBackpressureLatestonErrorResumeNextOperators onErrorReturn, onErrorResumeNext, onExceptionResumeNext #3237onErrorReturnOperators onErrorReturn, onErrorResumeNext, onExceptionResumeNext #3237onExceptionResumeNextOperators onErrorReturn, onErrorResumeNext, onExceptionResumeNext #3237publishreducestill awaiting review/decision on the scan bug in Scan backpressure and first emission fix #3171Operator scan, reduce. Fixes to TestSubscriber async behavior. #3255refCountonConnectableObservableOperator refCount #3246repeat(no scheduler)repeat(with scheduler) Operations doOnX. #3225 I suggest dropping this overload -> use compositionrepeatWhenOperator retryWhen, repeatWhen; Notification #3238 I'd like to implement this myself due to an elusive bug with retryWhen.replayretry(except the indexed predicate which I suggest droppingretryWhenOperator retryWhen, repeatWhen; Notification #3238 I'd like to implement this myself due to an elusive bug in itsampleOperator sample with time or with another publisher #3229scanstill awaiting review/decision on the scan bug in Scan backpressure and first emission fix #3171Operator scan, reduce. Fixes to TestSubscriber async behavior. #3255serializeOperator distinct, timeInterval, common Timed container. #3224shareOperators delay, delaySubscription, share. #3244single(no predicate)single(with predicate) I suggest dropping this -> use compositionsingleOrDefault(no predicate) as an overload to singlesingleOrDefault(with predicate) I suggest dropping this -> use compositionskip(untimed)skip(timed) Operator distinct, timeInterval, common Timed container. #3224skipLast(untimed)skipLast(timed) Operator takeLast time + size, skipLast time #3231skipUntilskipWhilestartWithsubscribesubscribeOnswitchIfEmptyOperato switchIfEmpty, defaultIfEmpty #3230switchMapOperator switchMap, switchOnNext, added missing merge and concat #3234take(untimed)take(timed) Operator distinct, timeInterval, common Timed container. #3224takeLast(untimed)takeLast(timed) Operator takeLast time + size, skipLast time #3231takeLastBufferOperator takeLast time + size, skipLast time #3231takeUntiltakeWhileOperator takeWhile #3239throttleFirstFixed debounce behavior, added throttleFirst, throttleLast alias #3256throttleLastFixed debounce behavior, added throttleFirst, throttleLast alias #3256throttleWithTimeoutOperator debounce (time, selector), throttleWithTimeout (alias) #3254timeIntervalOperator distinct, timeInterval, common Timed container. #3224timeoutOperator timeout, onBackpressureBuffer(onOverflow), fixes to parameter #3257timestampFixes to classes, convenience operators mostly. #3223toBlockingBlockingObservable, next, latest, mostRecent, first, last, single, #3245toListtoMapI suggest dropping thistoMultimapOperator collect, toMap and toMultimap based on it. #3226 I suggest dropping thistoSingleThis would require explicit dependency on 1.x or the complete implementation to be moved over to 2.x; a separate project would have been better...toSortedListunsafeSubscribeunsubscribeOnwindowWindow with count, count + skip. #3251, Operator window timespan, timespan + count, timespan + timeskip #3253, Operator window with boundary (exact, selector, exact + supplier). #3262withLatestFromOperator WithLatestFrom, PublishLift to help with operator fusing, #3222xlives on as a much simpler operatortozipWithFixes to classes, convenience operators mostly. #3223The text was updated successfully, but these errors were encountered: