Skip to content

4.x: Streamable + takeWhile, + fromXXX, + toObservable + ~.toStreamble#8214

Merged
akarnokd merged 1 commit into
ReactiveX:4.xfrom
akarnokd:4xStreamableOperators6
Jul 3, 2026
Merged

4.x: Streamable + takeWhile, + fromXXX, + toObservable + ~.toStreamble#8214
akarnokd merged 1 commit into
ReactiveX:4.xfrom
akarnokd:4xStreamableOperators6

Conversation

@akarnokd

@akarnokd akarnokd commented Jul 3, 2026

Copy link
Copy Markdown
Member

New operators:

  • Streamable.toObservable
  • Streamable.takeWhile
  • Streamable.fromCompletable
  • Streamable.fromMaybe
  • Streamable.fromSingle
  • Completable.toStreamable
  • Maybe.toStreamable
  • Single.toStreamable

Cleanup

  • Organize imports
  • Move Streamable.forEach code into StreamableForEach utility record

Marbles:

Completable

image

Maybe

image

Single

image

@github-actions

github-actions Bot commented Jul 3, 2026

Copy link
Copy Markdown

🐷 TruffleHog + Entropy Beauty Scan

Average entropy of changed code: 4.611 bits/char
Verdict: ✅ Mid-4 beauty detected (thoughtful human code!)

Changed files entropy:

src/main/java/io/reactivex/rxjava4/core/Streamable.java: 4.620
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableFromPublisher.java: 4.568
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableIntervalRange.java: 4.363
src/main/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableTimer.java: 4.557
src/test/java/io/reactivex/rxjava4/core/RxJavaTest.java: 4.547
src/test/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableBaseTest.java: 4.795
src/test/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableFromPublisherTest.java: 4.498
src/test/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableIntervalRangeTest.java: 4.761
src/test/java/io/reactivex/rxjava4/internal/operators/streamable/StreamableTimerTest.java: 4.642
src/test/java/io/reactivex/rxjava4/internal/schedulers/SharedSchedulerIsolatedTest.java: 4.837
src/test/java/io/reactivex/rxjava4/testsupport/TestHelper.java: 4.335
src/test/java/io/reactivex/rxjava4/validators/CheckParamValidationTest.java: 4.803

✅ No secrets or suspicious high-entropy strings found.

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

@codecov

codecov Bot commented Jul 3, 2026

Copy link
Copy Markdown

Codecov Report

❌ Patch coverage is 99.46809% with 1 line in your changes missing coverage. Please review.
✅ Project coverage is 98.67%. Comparing base (a318f0c) to head (c9891bf).

Files with missing lines Patch % Lines
...ternal/operators/streamable/StreamableForEach.java 97.05% 1 Missing ⚠️
Additional details and impacted files
@@             Coverage Diff              @@
##                4.x    #8214      +/-   ##
============================================
- Coverage     98.69%   98.67%   -0.02%     
- Complexity     6923     6953      +30     
============================================
  Files           793      799       +6     
  Lines         49022    49174     +152     
  Branches       6628     6646      +18     
============================================
+ Hits          48380    48524     +144     
- Misses          450      457       +7     
- Partials        192      193       +1     

☔ 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 31cddef into ReactiveX:4.x Jul 3, 2026
6 checks passed
@akarnokd akarnokd deleted the 4xStreamableOperators6 branch July 3, 2026 20:02
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