4.x: Flowable missing or incorrect marbles (tracking issue)
維護者通常 1 天內回覆
還沒有人認領這個 Issue。
評估
- 難度
- 5/5
- 預估耗時
- 一週以上
- 新手友好度
- 25/100
- Issue 類型
- 文件
- 描述清晰度
- 基本清楚
- 活躍度
- 停滯
- 技術堆疊
- java
研究方向
將 issue 檢查清單中未勾選的項目作為工作清單,從一個 Flowable 運算子及其缺少或不正確的 marble diagram 開始。閱讀 repository 中現有的運算子文件和圖表,然後確認所選圖表是否反映列出的名稱、參數、取消、請求傳播或回傳型別。完成表示目標檢查清單項目已獲得準確處理並勾選。
由索引模型根據 Issue 內容生成。
描述
-
amb: indicate cancellation and request propagation -
ambArray: indicate cancellation and request propagation -
combineLatest+ 4: missing diagram -
combineLatestDelayError+ 5: missing diagram -
concatArrayDelayError: operator name, indicate error delayed -
concatArrayEager+ 1: missing diagram -
concatArrayEagerDelayError+ 1: missing diagram -
concatDelayError+ 2: missing diagram -
concatEager+ 4: missing diagram -
concatEagerDelayError+ 4: missing diagram -
create: missing diagram -
error(Callable): indicate callback that creates the Throwable - `error(Throwable): indicate parameter
-
fromArray: operator name, indicate items inside the box -
fromCallable: indicate item is the result of the callback inside the box -
fromFuture+ 3: operator name -
fromIterable: operator name, indicate items inside the box -
fromPublisher: missing diagram -
generate+ 4: missing diagram -
intervalRange+ 1: missing diagram -
just+ 8: indicate item inside the box (as many as there are sources, so 1..9) -
mergeArray+ 1: operator name -
mergeArrayDelayError+ 1: operator name -
mergeDelayError+ 1: indicate inner sources are generated -
sequenceEqual+ 3: indicate cancellation after the mismatch has been found -
switchOnNextDelayError+ 1: operator name, indicate error delay -
using+ 1: indicate actual Flowable and items -
zipArray: operator name -
zipIterable: operator name -
all: should return Single -
ambWith: indicate cancellation and request propagation -
exists: should return Single -
: operator removedas: missing diagram -
blockingFirst+ 1: missing diagram -
blockingForEach: operator name -
blockingIterable+ 1: operator name, indicate iterator call tohasNext()andnext() -
blockingLast+ 1: operator name -
blockingLatest: missing diagram -
blockingMostRecent: operator name -
blockingNext: operator name -
blockingSingle+ 1: operator name -
toFuture: rework diagram to indicateFuture -
blockingSubscribe+ 4: missing diagram -
buffer(..., Callable)+ 6: indicate custom collection -
buffer(open, close)+ 1: parameter name in the box -
collect: indicate initial container supplier, should return Single -
collectInto: indicate initial container, should return Single, operator name -
compose: missing diagram -
concatMap(prefetch): indicate prefetch effects through requests -
concatMapDelayError+ 1: missing diagram -
concatMapEager+ 1: missing diagram -
concatMapEagerDelayError+ 1: missing diagram -
concatMapIterable+ 1: missing diagram -
concatWith: operator name -
contains: should return Single -
count: operator name -
defaultIfEmpty: indicate non-empty case -
delaySubscription(Publisher): missing diagram -
dematerialize: indicate dematerializing a terminal notification cancels the source -
doFinally: missing diagram -
doAfterNext: missing diagram -
doOnCancel: operator name, unsubscribe -> cancel in text -
doOnComplete: indicate events pass through -
doOnEach+ 1: indicate events pass through -
doOnError: indicate events pass through -
doOnNext: indicate events pass through -
doOnRequest: missing diagram -
doOnTerminate: indicate events pass through, show both error and complete case -
elementAt: should return Maybe, indicate if source is shorter than index -
elementAtOrDefault: should return Single, indicate if source has that element -
elementAtOrError: should return Single, indicate error case -
firstElement: image aspect off, add case separator dashed vertical line -
first: image aspect off -
firstOrError: combine two sections, vertical separator, empty source arrow -
flatMap(..., delayError): indicate error delay case -
flatMap(..., maxConcurrency)+ 2: missing diagram -
flatMap(Function, Function, Callable, int): missing diagram -
flatMap(Function, BiFunction, boolean, int)+ 1: missing diagram -
flatMap(Function, BiFunction, int): missing diagram -
flatMapCompletable+ 1: missing diagram -
flatMapIterable+ 1: image aspect looks off -
flatMapMaybe+ 1: missing diagram -
flatMapSingle+ 1: missing diagram -
forEach: missing diagram -
forEachWhile+ 2: missing diagram -
hide: missing diagram -
isEmpty: should return Single -
lastElement: operator name, should return Maybe -
last(T): should return Single, operator name -
lastOrError: combine sections into one, add vertical case separator -
limit:missing diagramoperator renamed totake -
mergeWith: operator name, indicate the second source as parameter -
onErrorResumeNext(Function): indicate error function -
onErrorReturn: indicate error function -
onErrorReturnItem: operator name -
onTerminateDetach: missing diagram -
publish(Function)+ 1: rework diagram -
rebatchRequests: missing diagram -
reduce(seed, ...): indicate star as parameter -
reduceWith(Callable,...): indicate star as a supplied value, operator name -
repeat+ 1: indicate resubscription -
repeatUntil: indicate boolean supplier -
replay+ 7: remove publish box -
replay(Function)+ 7: rework diagram -
retry(): indicate infinte resubscription -
retry(BiPredicate): indicate function decision on retry -
retry(long): indicate retry count effect -
retry(long, Predicate): indicate predicate effects -
retry(Predicate): indicate predicate effects -
retryUntil: missing diagram -
scan(R, ...): indicate initialValue as parameter -
scan(Callable, ...): indicate initialValue is the result of a call -
share: indicate the source gets cancelled -
singleElement: operator name, should return Maybe -
single: operator name, should return Single -
singleOrError: combine cases into one box, add vertical case separators -
skipUntil: indicate until cancels the main source -
sorted+ 1: missing diagram -
startWith(Iterable): indicate iterable parameter, indicate subscription -
startWith(Publisher): indicate subscription after the start element(s) -
startWith(T): one start value, indicate subscription after the start element -
startWithArray: operator name, indicate subscription after the start element(s) -
switchMapDelayError+ 1: operator name, indicate error is delayed -
takeUntil(Predicate): indicate source is cancelled -
takeUntil(Publisher): indicate source is cancelled -
takeWhile: indicate source is cancelled -
to: missing diagram -
toList+ 1: should return Single -
toList(Callable): should return Single, indicate custom collection -
toMap+ 2: should return Single -
toMultimap+ 3: should return Single -
toObservable: missing diagram -
toSortedList+ 4: should return Single -
unsubscribeOn: missing diagram -
withLatestFrom(s1, s2, ...): missing diagrams -
withLatestFrom(Publisher[], ...): missing diagram -
withLatestFrom(Iterable, ...): missing diagram
- 主要語言
- Java
- 星號
- 48.2k
- 分支
- 7.6k
- 平均合併
- 1 小時 46 分鐘
- 30 天內合併 PR
- 25
環境準備
- 沒有 Dockerfile 或 Docker Compose 檔案
- 有 Pull Request 範本
- 閱讀貢獻指南
從這裡開始
- 先讀完整個 Issue,再讀專案的貢獻指南。
- 在 Issue 下留言說明你要接手 —— 這能避免兩個人做同樣的事。
- Fork 儲存庫,在一個分支上完成修改。
- 送出 Pull Request,並在描述裡引用這個 Issue 編號。
ReactiveX/RxJava 的其他 Issue
-
4.x Streamable Test-Failures
難度 4/5 3-5 天 新手友好度 45/100
維護者通常 1 天內回覆
-
4.x AI Enhancement Streamable
難度 4/5 3-5 天 新手友好度 45/100
ReactiveX/RxJava#8299 · 1 則留言 ·
維護者通常 1 天內回覆
-
4.x: FlowableBufferTest > longTimeAction() FAILED可能重新可做 @akarnokd 於 82 天前認領,目前沒有進行中的 PR。 未關閉4.x Test-Failures
ReactiveX/RxJava#8280 · 已指派 1 人 ·
維護者通常 1 天內回覆
-
4.x Discussion
難度 5/5 一週以上 新手友好度 25/100
維護者通常 1 天內回覆
-
4.x PR welcome Test Test-Failures
難度 4/5 3-5 天 新手友好度 45/100
ReactiveX/RxJava#8075 · 4 則留言 ·
維護者通常 1 天內回覆
相似的 Issue
-
good first issue
難度 2/5 1-3 小時 新手友好度 90/100
authorjapps/zerocode#808 ·
-
難度 2/5 1-3 小時 新手友好度 65/100
checkstyle/sonar-checkstyle#625 ·
-
難度 2/5 1-3 小時 新手友好度 82/100
維護者通常 1 天內回覆
-
難度 1/5 1 小時以內 新手友好度 88/100
quarkusio/quarkus-agent-mcp#302 ·
維護者通常 2 天內回覆
-
build
難度 1/5 1 小時以內 新手友好度 85/100
MetricsHub/metricshub-community#1472 ·
維護者通常 1 天內回覆