Skip to content

4.x: Streamable +blockingFirst, last[OrError], skip, Single.flattenAsStreamable#8229

Merged
akarnokd merged 1 commit into
ReactiveX:4.xfrom
akarnokd:4xStreamableOperators105
Jul 9, 2026
Merged

4.x: Streamable +blockingFirst, last[OrError], skip, Single.flattenAsStreamable#8229
akarnokd merged 1 commit into
ReactiveX:4.xfrom
akarnokd:4xStreamableOperators105

Conversation

@akarnokd

@akarnokd akarnokd commented Jul 9, 2026

Copy link
Copy Markdown
Member

Streamable

  • blockingFirst
  • last
  • lastOrError
  • skip

ℹ️ Preparing minimal operators for the Shakespeare Plays Scrabble benchmarks.

Single

  • flattenAsStreamable

Other

  • DisposableOnly to avoid the need to cover a generally never called isDisposable. Operators will be updated later to use it.
  • Fix documentation reported by the (updated) validator tests.

@github-actions

github-actions Bot commented Jul 9, 2026

Copy link
Copy Markdown

🐷 TruffleHog + Entropy Beauty Scan

Average entropy of changed code: 4.729 bits/char
Verdict: ⚠️ Consider review — entropy outside sweet spot

Changed files entropy:

src/main/java/io/reactivex/rxjava4/core/Completable.java: 4.834
src/main/java/io/reactivex/rxjava4/core/Maybe.java: 4.843
src/main/java/io/reactivex/rxjava4/core/Single.java: 4.831
src/main/java/io/reactivex/rxjava4/core/Streamable.java: 4.653
src/main/java/io/reactivex/rxjava4/internal/disposables/DisposableOnly.java: 4.911
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/StageResumable.java: 4.712
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableBlocking.java: 4.721
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableLastAsSingle.java: 4.371
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableSingleFlattenAs.java: 4.537
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableSkip.java: 4.553
src/test/java/io/reactivex/rxjava4/disposables/DisposableTest.java: 4.614
src/test/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableBaseTest.java: 4.751
src/test/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableBlockingTest.java: 4.930
src/test/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableDeferTest.java: 4.822
src/test/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableFailingFinish.java: 4.763
src/test/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableLastAsSingleTest.java: 4.789
src/test/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableSingleFlattenAsTest.java: 4.862
src/test/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableSkipTest.java: 4.738
src/test/java/io/reactivex/rxjava4/validators/CheckBaseTypeAnnotationsTest.java: 4.496
src/test/java/io/reactivex/rxjava4/validators/CheckParamValidationTest.java: 4.845

✅ No secrets or suspicious high-entropy strings found.

Mid-4 beauty heuristic in action — powered by our entropy chats! 😊

@codecov

codecov Bot commented Jul 9, 2026

Copy link
Copy Markdown

Codecov Report

❌ Patch coverage is 99.33333% with 1 line in your changes missing coverage. Please review.
✅ Project coverage is 98.72%. Comparing base (b6b09c6) to head (99e0849).

Files with missing lines Patch % Lines
...ernal/operators/streamable/StreamableBlocking.java 95.23% 1 Missing ⚠️
Additional details and impacted files
@@             Coverage Diff              @@
##                4.x    #8229      +/-   ##
============================================
+ Coverage     98.69%   98.72%   +0.02%     
- Complexity     7097     7117      +20     
============================================
  Files           814      819       +5     
  Lines         50026    50176     +150     
  Branches       6764     6786      +22     
============================================
+ Hits          49373    49535     +162     
+ Misses          452      447       -5     
+ Partials        201      194       -7     

☔ View full report in Codecov by Harness.
📢 Have feedback on the report? Share it here.

🚀 New features to boost your workflow:
  • ❄️ Test Analytics: Detect flaky tests, report on failures, and find test suite problems.

@akarnokd akarnokd merged commit cc40f64 into ReactiveX:4.x Jul 9, 2026
6 checks passed
@akarnokd akarnokd deleted the 4xStreamableOperators105 branch July 9, 2026 18:46
@akarnokd akarnokd changed the title 4.x: Streamable +blockingFirst,last[OrError],skip ,S.flattenAsStreamable 4.x: Streamable +blockingFirst, last[OrError] ,skip, Single.flattenAsStreamable Jul 9, 2026
@akarnokd akarnokd changed the title 4.x: Streamable +blockingFirst, last[OrError] ,skip, Single.flattenAsStreamable 4.x: Streamable +blockingFirst, last[OrError], skip, Single.flattenAsStreamable Jul 9, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant