Skip to content

4.x: Streamable optimizations 2026.07.21 - #8254

Merged
akarnokd merged 5 commits into
ReactiveX:4.xfrom
akarnokd:4xStreamableOptimizations721
Jul 29, 2026
Merged

4.x: Streamable optimizations 2026.07.21#8254
akarnokd merged 5 commits into
ReactiveX:4.xfrom
akarnokd:4xStreamableOptimizations721

Conversation

@akarnokd

Copy link
Copy Markdown
Member
  • Streamable.skip optimization + fusion support
  • Streamable.take optimization + fusion support
  • Marker interfaces for the Streamable
  • DisposableStreamerCancellation adjustments, blockingXXX external cancellation support.

@github-actions

Copy link
Copy Markdown

🐷 TruffleHog + Entropy Beauty Scan

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

Changed files entropy:

src/jmh/java/io/reactivex/rxjava4/streamable/StreamableSkipPerf.java: 4.813
src/main/java/io/reactivex/rxjava4/core/Streamable.java: 4.646
src/main/java/io/reactivex/rxjava4/disposables/DisposableStreamerCancellation.java: 4.770
src/main/java/io/reactivex/rxjava4/internal/disposables/NeverDisposableStreamerCancellation.java: 4.773
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/IsEnumerableStreamable.java: 4.978
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/IsIndexableStreamable.java: 4.979
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/IsSynchronousStreamable.java: 5.008
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableBlocking.java: 4.580
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableEmpty.java: 4.809
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableJust.java: 4.676
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableRange.java: 4.580
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableRangeLong.java: 4.541
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableSkip.java: 4.364
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableTake.java: 4.562
src/test/java/io/reactivex/rxjava4/internal/operators/streamable/DisposableStreamerCancellationTest.java: 4.867
src/test/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableBlockingLastTest.java: 4.913
src/test/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableSkipTest.java: 4.727
src/test/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableTakeTest.java: 4.708

✅ No secrets or suspicious high-entropy strings found.

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

@github-actions

Copy link
Copy Markdown

🐷 TruffleHog + Entropy Beauty Scan

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

Changed files entropy:

src/jmh/java/io/reactivex/rxjava4/streamable/StreamableSkipPerf.java: 4.813
src/main/java/io/reactivex/rxjava4/core/Streamable.java: 4.647
src/main/java/io/reactivex/rxjava4/disposables/DisposableStreamerCancellation.java: 4.770
src/main/java/io/reactivex/rxjava4/internal/disposables/NeverDisposableStreamerCancellation.java: 4.773
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/IsEnumerableStreamable.java: 4.978
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/IsIndexableStreamable.java: 4.979
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/IsSynchronousStreamable.java: 5.008
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableBlocking.java: 4.580
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableEmpty.java: 4.809
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableJust.java: 4.676
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableRange.java: 4.580
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableRangeLong.java: 4.541
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableSkip.java: 4.364
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableTake.java: 4.562
src/test/java/io/reactivex/rxjava4/internal/operators/streamable/DisposableStreamerCancellationTest.java: 4.867
src/test/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableBlockingLastTest.java: 4.913
src/test/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableFromStreamTest.java: 4.836
src/test/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableSkipTest.java: 4.727
src/test/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableTakeTest.java: 4.708
src/test/java/io/reactivex/rxjava4/validators/CheckParamValidationTest.java: 4.846

✅ No secrets or suspicious high-entropy strings found.

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

@akarnokd
akarnokd merged commit ddcbd7b into ReactiveX:4.x Jul 29, 2026
5 checks passed
@akarnokd
akarnokd deleted the 4xStreamableOptimizations721 branch July 29, 2026 16:44
@codecov

codecov Bot commented Jul 29, 2026

Copy link
Copy Markdown

Codecov Report

❌ Patch coverage is 97.27273% with 3 lines in your changes missing coverage. Please review.
✅ Project coverage is 98.59%. Comparing base (db01b1f) to head (b7ac3ae).
⚠️ Report is 1 commits behind head on 4.x.

Files with missing lines Patch % Lines
.../internal/operators/streamable/StreamableSkip.java 94.73% 1 Missing and 2 partials ⚠️
Additional details and impacted files
@@             Coverage Diff              @@
##                4.x    #8254      +/-   ##
============================================
- Coverage     98.62%   98.59%   -0.04%     
- Complexity     7129     7145      +16     
============================================
  Files           822      824       +2     
  Lines         50690    50768      +78     
  Branches       6892     6905      +13     
============================================
+ Hits          49993    50053      +60     
- Misses          477      487      +10     
- Partials        220      228       +8     

☔ 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.

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