reactor/reactor-core v3.3.3.RELEASE

on GitHub

reactor-core 3.3.3.RELEASE is part of Californium-SR16 Release Train.

⚠️ Update considerations and deprecations

• Added a defer opt-in in VirtualTimeScheduler.create (#1251, #2012)
  • Manually-created VirtualTimeScheduler will now eagerly advance time even if there is no pending task. Use the overload with defer=true to get the old default behavior.
  • StepVerifier-created ones will continue lazily advancing time when no task is scheduled, in order to make testing of things like delays inside a flatMap possible.
• For users of fromStream and fromIterable with custom non-Collection Iterables, see #2014 and #2021
  • the iterator() method is now invoked twice per wrapping of a given Iterable (once through default spliterator() to check the iterable is finite aka. hasCharacteristic(SIZED), once for the iteration itself)

✨ New features and improvements

• Fixed Flux.replay / Flux.cache hanging or serving wrong values, by correctly replaying request(UNBOUNDED) when no early subscriber (#2030, #2028)
• Propagate all req from FluxReplay pre-connect subscribers (#1921)
• Reimplemented boundedElasticScheduler to allow reentrancy (#1992, #2040, #1973)
  • Multiple subscribeOn calls with a BoundedElasticScheduler could easily cause deadlock
  • This also fixes #1973, although there was an intermediate fix in the old implementation
• From 3.2.15:
  • Discard concatMapIterable/fromIterable's remainder on Cancel (#2014)
    • the remainder of the internal Iterator is discarded when cancelled mid-iteration
    • we avoid the risk of iterating an infinite iterator by first checking if the Iterable is a Collection or its Spliterator has the SIZED characteristic.
    • the above check can result in at most 2 calls to Iterable#iterator for custom iterables
  • [polish] Improve onDiscardMultiple/QueueWithClear resiliency (#2021)

🪲 Bug fixes

• Avoid parallel insertion in Context's default putAll with foreign Context implementation (#2050)
• From 3.2.15:
  • Account for requests made to upstream in FluxBufferPredicate (#1937, #2029)
  • collect() discards on consumer error when fused (#2042)
  • Unconditionally dispose worker in MonoSubscribeOn#cancel (#2037)
  • Pass on cancelSupport when lifting ConnectableLiftFuseable (#1860)
  • Correctly count continued errors on flatmapped callable (#2011)
  • Handle "empty Callable" in Flux#collectList (#2023, #2024)
  • Fix fused last(T) not delivering defaultValue (#2020)

📖 Documentation, Tests and Build

• Document Flux#next() behavior for an empty Flux (#1899)

👍 Thanks to the following contributors that also participated to this release

@btkelly, @ilyavy, @robotmrv, @yarosla