Repository navigation

4.x: Streamable + doOnError, forEach(StreamSink) - #8218

Merged

akarnokd merged 8 commits into

ReactiveX:4.xfrom

akarnokd:4xStreamableOperators102

Jul 7, 2026

Merged

4.x: Streamable + doOnError, forEach(StreamSink)#8218
akarnokd merged 8 commits into
ReactiveX:4.xfrom
akarnokd:4xStreamableOperators102

Commits on Jul 6, 2026
- 4.x: Streamable + doOnError, forEach(StreamerInput)
  akarnokd
  committed
  682143a
- fix tests
  akarnokd
  committed
  07ec596
Commits on Jul 7, 2026
- Improve API, fix bugs, add coverage
  akarnokd
  committed
  c1efe46
- fix style
  akarnokd
  committed
  be8e201
- Fix flaky DispatchStreamProcessorTest > normalMulti()
  akarnokd
  committed
  ee5956e
- improve coverage of withCancellation, rename to StreamSink
  akarnokd
  committed
  f74b39c
- Remove ThrowableWrapper, fix attempt at flaky tests
  akarnokd
  committed
  ca2568c
- flaky forEachInputCancelUpfront fix?
  akarnokd
  committed
  48a5a62