Changelog History
Page 2
-
v3.3.8.RELEASE Changes
July 20, 2020๐ Reactor-Core
3.3.8.RELEASE
is part ofDysprosium-SR10
Release Train.๐ This maintenance release is a recommended update for all Reactor 3 users.
๐ This version also contains all changes from v3.2.19.RELEASE.
๐ฑ ๐ Bug fixes
- ๐ Handle
null
publisher inMonoDelayUntil
(#2245) - ๐ fix #2260 Avoid onSubscribe race in FluxTimeout (#2266)
๐ ๐ Documentation, Tests and Build
- โฑ [doc] Fix Scheduler Javadoc (#2190)
- [doc] fix #2199 Fix typo in reference guide
- ๐ [build] fix #2264 add blockhound to testset
- [doc] Fix small error in TupleUtils asciidoc (#2201)
- ๐ [polish] fix #2246 Remove usage of globalRegistry in metrics tests
- ๐ [polish] FluxUsingWhenTest awaitility + order of capturing subscription
- [doc] fix #2257 Improve flatMapIterable prefetch javadoc
๐ ๐ Thanks to the following contributors that also participated to this release
- ๐ Handle
-
v3.3.7.RELEASE Changes
June 25, 2020๐ reactor-core
3.3.7.RELEASE
is part ofDysprosium-SR9
Release Train.๐ฑ โจ New features and improvements
๐ฑ ๐ Bug fixes
- Align MonoCollect and MonoCollectList to avoid race condition which leads to NullPointerException (#2186)
- ๐ Handle nulls from collectors in
Flux.collect()
(#2181)
๐ ๐ Documentation, Tests and Build
- โฑ [test] Improve thread regrowth test of boundedElastic/Elastic by considering negative values that might be produced as 0 (no regrowth, aka no increase in the number of active threads from the scheduler).
- ๐ [build] Ensure tools fat jar is the one published (#2189)
- ๐ [build] Fix input package rule for OSGi metadata generator (#2185)
๐ ๐ Thanks to the following contributors that also participated to this release
-
v3.3.6.RELEASE Changes
June 25, 2020๐ Reactor-Core
3.3.6.RELEASE
is part ofDysprosium-SR8
Release Train.๐ฑ โจ New features and improvements
- Ensure
DeferredSubscription
makes requests serially if there is racing between set / requestN (according to RS spec Rule 2.7)(#2164) - Ensure
FluxSwitchOnFirst
serializes requests (according to RS spec Rule 2.7) (#2161) - Ensures next element is dropped if
UnicastProcessor
disposed to avoid racing betweenonNext
anddispose
(#2180) - โฑ Use
ZoneId.of(String)
to avoid blocking disk load during first access ofSchedulers.boundedElastic()
(#2143)
๐ฑ ๐ Bug fixes
- Accommodate
ASYNC
fusion inMono.metrics()
to avoidNullPointerException
or hanging in certain cases (#2160 ) - ๐ Fix volatile read of first element and
ConditionalSubscriber
classcast inFluxSwitchOnFirst
(#2166) - ๐ Change the
Subscription
set byreportThrowInSubscribe
to an instance compatible withQueueSubscription
, preventing fused cases where a ClassCastException would be thrown. (#2152 )
๐ ๐ Documentation, Tests and Build
- โ
[test] Fix
publishOn
scan test, hiccup before assertingBUFFERED
- ๐ [doc] Better describe
Mono.first()
andMono.or()
behavior (#2159) - [doc] Fix typo
Retry.fromFunction()
instead offrom()
(#2172) - [doc] Fix
RetrySpec
doc:throwablePredicate
is actually filter (#2162) - [doc] Document
onCancel
/onDipose
limited to 1 use (#2015) - ๐ [doc] Remove wrong curly braces in
generate
code example (#2110) - ๐ [build] Have blockHoundTest fork JVM on every case (see #2144)
- ๐ [build] Consistently use tabs for gradle file indentation (#2157)
- ๐ [publication] Publish Gradle metadata, without optional dependencies (#2151)
๐ ๐ Thanks to the following contributors that also participated to this release
@alex-dukhno , @chakas , @berry120 , @OlegDokuka , @PyvesB , @josemalonsom
- Ensure
-
v3.3.5.RELEASE Changes
April 27, 2020๐ reactor-core
3.3.5.RELEASE
is part ofDysprosium-SR7
Release Train.๐ It also contains all fixes from 3.2.17.RELEASE.
โก๏ธ โ ๏ธ Update considerations and deprecations
- A corner case of throwing from the
subscribe
method can lead to twoonSubscribe
signal if said exception is thrown after having sent theSubscription
(#2107, #2111, #2072) - Most well-formed subscribers will ignore this, but
StepVerifier
cannot, which can "hide" the true error - This potentially extra
Subscription
can be identified withOperators.canAppearAfterOnSubscribe(Subscription)
, which is used byStepVerifier
to ignore that particular extra subscription
๐ฑ โจ New features and improvements
- Unify error-handling in
subscribe
/subscribeOrReturn
mutualized implementation, preventStepVerifier
getting confused by a doubleonSubscribe
in that very specific case ((#2072, #2107, #2111) - ๐ [tools] Support build-time debug instrumentation (#2105)
- ๐ [tools] Support running reactor-tools as a "normal" Java Agent (#2104, #2098)
- From 3.2.17:
- Cover several cases of
onNext
vscancel
races that would bypass resource discarding (#2134, #2126, #2102, #2124, #2125, #2122, #2077, #2102) - Including backport and complement of fixes to UnicastProcessor (#2124, #2125, #980, #2126)
- Flux#from and Mono#flux consistently apply onAssembly hooks (#2055, #2067)
- Flux#from/wrap does not call Flux#onAssembly
- Flux#from and Mono#flux apply onAssembly hooks
- Cover several cases of
๐ฑ ๐ Bug fixes
- ๐ Fix DefaultStepVerifierBuilder#onSubscribe error format (#2106)
- From 3.2.17:
- Propagate rejection error from
MonoDelayElement#onNext
downstream
- Propagate rejection error from
๐ ๐ Documentation, Tests and Build
- โ
[test] Don't reuse same exception in
errorOnSubscribe
steps (#2112) - ๐ [doc] Polish doc of Iterable operators, clarify iterator() calls (#2135, #2014, #2127)
- โ
[test] Split
errorOnSubscribe
scenarios into separate tests (#2099) - ๐ [build] Follow-up to #2088 bump to Gradle 6.3 : 3.3 specifics (#2088, #2089)
- ๐ Polish docs, code compilation warnings, flakkt tests, etc... (#2087, #2084, #2084)
- โ
[test] Use JUnit Jupiter's
@TestFactory
inBaseOperatorTest
(#2085) - โ [test] Use JUnit Platform + Vintage engine (#2073)
- โ [test] Add a post-test listener that resets hooks consistently (#2082)
- from 3.2.17
- [test] Extract Tracked to MemoryUtils, add OffHeapDetector (#2125)
- [test] Provides tests suite to expose onDiscard leaks and fixes (#2125)
- Create CODEOWNERS (#2097)
- [build] Test with JDK 14, bump to Gradle 6.3 (#2088)
- [test] Remove testStaticInit task, verify in main test task (#2093)
- [Polish] Split bndoptions elements in array for clarity (#2091)
- [build] Simplify stubbing for Java 9+ (#2091)
- [build] Backport gradle/releaser.gradle to 3.2 (e4fe960)
๐ ๐ Thanks to the following contributors that also participated to this release
- A corner case of throwing from the
-
v3.3.3.RELEASE Changes
February 24, 2020๐ reactor-core
3.3.3.RELEASE
is part ofCalifornium-SR16
Release Train.โก๏ธ โ ๏ธ Update considerations and deprecations
- โ Added a
defer
opt-in inVirtualTimeScheduler.create
(#1251, #2012)- Manually-created
VirtualTimeScheduler
will now eagerly advance time even if there is no pending task. Use the overload withdefer=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 aflatMap
possible.
- Manually-created
๐ฑ โจ 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 aCollection
or itsSpliterator
has theSIZED
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
- 0๏ธโฃ 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
" inFlux#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
- โ Added a
-
v3.3.2.RELEASE
January 13, 2020 -
v3.3.1.RELEASE Changes
December 02, 2019๐ Reactor-Core
3.3.1.RELEASE
is part ofDysprosium-SR2
Release Train.๐ It also includes changes from the 3.2.13.RELEASE version.
โ One important change to pick up for testing Reactor is in
StepVerifier
: the combination ofexpectNoEvent
followed bythenCancel
wasn't working terribly well, and a new better terminal expectation has been introduced:expectTimeout
(#1913)โก๏ธ โ ๏ธ Update considerations and deprecations
- โฑ #1911 Instrument ScheduledExecutorService via Micrometer
- Instead of doing our own executor decorator we now rely on the Micrometer one, but it might have different coverage of tasks
๐ฑ โจ New features and improvements
- ๐ #1557 Removed greediness from FluxBufferTimeout
- ๐ #1938 Remove overeager toString calls in FluxIndexFuseable
- #1913
StepVerifier
:expectTimeout(Duration)
as an alternative toexpectNoEvent(Duration).thenCancel()
- #1902 When
transform
ortransformDeferred
apply a transformation to a non-ReactorPublisher
, warn when/if the originalContext
is lost (#1888) - #1966 Internal simplification of how the comparator is applied in
collectSortedList
- ๐จ #1962 Avoid extending
Map.Entry
inContext1
to ensure various libraries don't represent it inconsistenly when printing out collections ofContext
- #1963 Retain insertion order in
ContextN
(by extendingLinkedHashMap
instead ofHashMap
) - ๐ changes from 3.2.13.RELEASE:
- #1916 Interpret MAX_VALUEms as indefinite caching in
Mono#cache(Function, Function, Supplier)
(backported) - #1746 Add
VirtualTimeScheduler#getScheduledTaskCount()
(backported) - #1968 Make
Flux#publish()
propagate 1st subscriberContext
- #1953 Add
Exceptions.isTraceback
, and a mean to unwrap a composite without the tacebacks (Exceptions.unwrapMultipleExcludingTracebacks
)
- #1916 Interpret MAX_VALUEms as indefinite caching in
๐ฑ ๐ Bug fixes
- ๐ changes from 3.2.13.RELEASE:
๐ ๐ Documentation, Tests and Build
- [doc] #1908 Marble diagram for
bufferWhile
was incorrectly showing dropped separators - [doc] #1915
Flux#join
javadoc and marble have been clarified - ๐ [dependency] Bumped BlockHound to the release version (#1923)
- ๐ [build] Reorganization of the build with separation of concerns (buildSrc, gradle.properties, etc...) (0bd50de, a1dab8a)
- ๐ [build] Add reactor.blockhound to OSGI optional bundles (#1932, #1933)
- ๐ [build] Prepare for a releasetrain releaser script: add new tasks, allow mavenLocal source (06977a6, #1960)
- ๐ changes from 3.2.13.RELEASE:
- [build] Switched to Gradle 5.6 (8e97f91)
- [build] Switched publication plugin to
maven-publish
andartifactory
(#1943) - [build] Fixed generation of refguide pdf when custom version is used (2c621b6)
- [polish]
Exceptions.multiple(Iterable)
now produces aCompositeException
, more test coverage ofExceptions
util (#1954)
๐ ๐ Thanks to the following contributors that also participated to this release
@andreisilviudragnea, @akarnokd, @berry120, @dittos, @EleanorRoseLegg, @gindex, @jabrena, @simondaudin, @slisaasquatch, @thiyagu-7, @ttddyy, @slisaasquatch, @wonwoo
-
v3.3.0.RELEASE Changes
September 25, 2019๐ Reactor-Core
3.3.0.RELEASE
is part ofDysprosium-RELEASE
Release Train.๐ This release note covers the first GA release of the 3.3.x cycle, and as such describes the changes from the perspective of a 3.2.x to 3.3.0 comparison.
๐ See also release notes from 3.2.12, 3.2.11, 3.2.10 and 3.2.9 for changes that were inherited from the 3.2.x maintenance releases.
๐ This release is a big opportunity to polish the APIs and some behaviors with less restriction than maintenance releases.
โฑ ๐ It also introduces a few new features, the highlight of which is the
BoundedElasticScheduler
:
โฑ this one has evolved from theElasticScheduler
and is intended as a future replacement for it.
โฑ A cap can be put on the number of threads such a scheduler can spawn. After that cap is reached, further task submissions are deferred (being enqueued) up to a second global limit on enqueued tasks (optionally unbounded).โก๏ธ โ ๏ธ Update considerations and deprecations
- (from RC1:)
- A few Mono operators have slightly changed their behavior in regards to how when they propagate
onNext
: they could triggeronError
afteronNext
, which is not permitted in Mono.Mono#usingWhen
now waits for the async complete handler termination before propagatingonNext
(#1832)Mono#using
similarly avoids triggering onNext+onError if cleanup fails (#1853)Mono#doOnTerminate
now acts similarly todoOnSuccess
, executing the side effect before theonNext
is propagated downstream (#1752)
- ๐
Mono#do[On|After]SuccessOrError
has been deprecated and marked for removal in 3.4 (#1854) - ๐
usingWhen
API has been polished, and some variants deprecated for removal in 3.4 (#1687)- A new overload has been introduced that uses
BiFunction
for error handler (exposing the failure that causes "rollback") - A single-handler version has been added to
Mono
for alignment withFlux
. This is the simplest case: same handler for complete, error and cancel terminations. - All other overloads have been deprecated. Goal is to favor either the simple 1-handler-covers-all case OR force users to be explicit about ALL possible terminations.
- A new overload has been introduced that uses
- (from M3:)
- ๐ #1742 Processors and Kotlin extensions deprecations
- ๐ the
WorkQueueProcessor
andTopicProcessor
have been marked as deprecated for 3.3.x and will be removed in 3.4 - ๐ have been deprecated, due to underlying use of
Unsafe
- Recommended core alternative is to combine
EmitterProcessor
andpublishOn
- ๐ the Kotlin extensions are deprecated in core and replaced by a dedicated project/repo,
reactor-kotlin-extensions
- ๐ in both cases, the deprecated classes don't appear in the generated javadoc jar
- โฑ #1764 Deprecated method
Schedulers.Factory#decorateExecutorService
has been removed - #1669 All
onBackpressureBuffer(maxSize+error)
variants now delay errors - ๐ In debug mode, most of the original stacktrace is artificially moved at the end of the exception's output, after the "backtrace" (#1781)
- ๐ #1745
compose()
has been deprecated and renamedtransformDeferred()
- ๐ deprecated operator will be removed in 3.4
- ๐ฆ #1451 Dematerialize has been reworked and now expects 1 request per upstream
Signal
- ๐ฆ This avoids
onNext
events to be emitted only when the subsequent signal is ready upstream - ๐ฆ This also means that in order to get a terminal signal like
onComplete
signal, the correspondingSignal
must be explicitly requested from upstream (one extrarequest(1)
) - (from M2:)
- Exceptions are now unwrapped (
Exceptions#unwrap
) in most sources that immediately produce an error, acting like aCallable
(b6f4d29) - ๐ Moved
reactor-tools
sources into the core repository (#1731)
๐ฑ โจ New features and improvements
- โฑ ๐ Added a
boundedElastic
Scheduler that caps number of threads and scales to 0 (#1804)- global singleton also cap deferred tasks past the thread limit to 100K (32d2a29)
- thread cap and task queue capacity can be configured separately, the later can even be unbounded
- โ Add windowUntilChanged operator, ensure the stateful predicate is subscriber-specific and cleaned on cancel (#1850, #1901)
- ๐ Improve the naming (eg.
scan(Attr.NAME)
ortoString
) of global singleton Schedulers (#1885, #1886)- for instance, instead of
parallel(parallel)
this is nowSchedulers.parallel()
- for instance, instead of
- ๐ Improvements around subscription recursivity / subscribe loop performance (#1882)
- Avoid extra lastAssembly by using CorePublisher where possible (#1883)
- (from RC1:)
- Due to a few Throwable constants, class references could leak in multi-classloader environments. This is now avoided by skipping the filling of the stacktrace (#1872)
- โ Add BufferUntilChanged operator (#1706, bb5b2bb)
- โ Added new StepVerifier API to subscribe to source and verify it later (#1848, b2ce5fe)
- (from M3:)
- โ Add "VirtualTimeScheduler#getScheduledTaskCount()" (#1746)
- #1763 Flux.parallel now uses
Schedulers.DEFAULT_POOL_SIZE
(which can be overridden by system property) - #1767 Add ParallelFlux#then to compose on parallel termination
- โฑ #1722 Make sure ElasticScheduler.CachedService gets disposed
- #1798 Use bounded wildcard in error(Supplier)
- ๐
Polish flux metrics (#1802)
- see also the other commits linked in that PR
- Actually record executor service metrics to Micrometer (#1795)
- โ Add a Context-aware {Mono,Flux}.deferWithContext (#1819)
- โก๏ธ Eliminate
subscribe
from stack by optimizing the "tail calls" (#1761, #1826) - #1416 Add lambda subscribe variants with a context
- (from M2:)
- Avoid triggering
Context
lookups in error sources (4f2bc7a) - Extended blockHound whitelist
- โ Remove unnecessary volatile with UnicastProcessor fusion (c86db5a)
- ๐ Improved cache eviction in ElasticScheduler (#1700)
- (from M1:)
- โ
Compatibility with projects using the Java Module System (JPMS) has been improved by declaring an official
Automatic-Module-Name
(reactor.core
andreactor.test
, #1641, #1692) - The
CorePublisher
interface has been introduced to distinguishPublisher
from reactor (#1527) - โ Add a simplified API for wrapping scheduled tasks (#1546)
- โ Add an API-preserving hide() method to ConnectableFlux (#1577)
- โ [reactor-test] Added hasDiscardedMatching method in StepVerifier (#1509)
- โ
[reactor-test] Add ToStringConverter and Extractor to StepVerifierOptions (#1558)
- This allows to override the natural
toString
representation of classes that are known to have an obscure representation, as well as extracting such objects that would be nested in containers like aCollection
,Tuple2
,Signal
, ...
- This allows to override the natural
- Reworked the format of "backtraces" (#1672, #1702)
- Backtraces are the additional callsite information captured by debug mode and checkpoint and appended to onError
Throwable
as a suppressed exception
- Backtraces are the additional callsite information captured by debug mode and checkpoint and appended to onError
- Reactor now integrates into Blockhound 1.0.0.M3 using the SPI on reactor side instead of programmatic explicit registration on blockhound side (#1682, #1690)
๐ฑ ๐ Bug fixes
- (from M2:)
- Avoid unbounded Flux.replay request with bounded subscribers (#1185)
- โ Removed "checkpoint" prefix in backtraces from return-only callsites (#1740)
- (from M1:)
- ๐ฆ [reactor-test] Prevent StepVerifier collect hang when consuming all signals (#1529)
- Unwrap CompletionException in Mono#fromFuture (#1652)
- ๐ Fix MonoProcessor#block duration.zero change (c995c01)
๐ ๐ Documentation, Tests and Build
- Document Java9stubs-related importing issues (#1680)
- [doc] Disambiguate lowTide example in limitRate javadoc
- Document reactor-tools in refguide (#1903)
- โ [internal test utils] Rework autoCleanup methods into a reusable JUnit Rule
- โ [internal test utils] Add direct assertion method on RetainedDetector
- (from RC1:)
- [doc] Add limitRate marble diagrams (#1449)
- ๐ [build] Polish benchmarks build, remove jmh plugin (#1844, 1ba4944)
- ๐ [build] Make it possible to run two JMH tasks - baseline and current (#1862)
- (from M3:)
- ๐ [build] Use "check" task as an aggregator, not "test" (#1776)
- ๐ [doc] #1539 Add "metrics" section to the reference guide (see also #1812, #1817)
- (from M2:)
- ๐ [build] JMH benchmarks are now in a separate sub-project, forked scrabble benchmark there (8895e94)
- ๐ [build] Log console output in Gradle ONLY for failed tests on CI (fc74beb)
- (from M1:)
- [doc] Document that BaseSubscriber instances can't be reused (#1490)
- ๐ [CI] Sanity check build on JDK12 on Travis (446ca1b)
- [doc] Use the correct marble diagram for Mono#onErrorResume (#1679)
- ๐ [build] Polish .gitignore to avoid too broad regex (92ae4e5)
๐ ๐ Thanks to the following contributors that also participated to the Dysprosium-RELEASE or pre-releases
@aftersss, @akarnokd, @apuravchauhan, @berry120, @Buzzardo, @dittos, @don-vip, @flambard, @gindex, @hisener, @izeye, @jnizet, @mumukiller, @OlegDokuka, @pcdavid, @pmackowski, @ramonPires, @szpak, @ttddyy, @UgiR, @zhouzhou19950825
-
v3.3.0.RC1 Changes
September 04, 2019๐ Reactor-Core
3.3.0.RC1
is part ofDysprosium-RC1
Pre-Release Train.๐ This first release candidate of the 3.3.x cycle contains bugfixes and improvements from the GA 3.2.12.RELEASE as well as a few new features. It also involves a few behavior impacting changes and deprecations.
โก๏ธ โ ๏ธ Update considerations and deprecations
- A few Mono operators have slightly changed their behavior in regards to how when they propagate
onNext
: they could triggeronError
afteronNext
, which is not permitted in Mono.Mono#usingWhen
now waits for the async complete handler termination before propagatingonNext
(#1832)Mono#using
similarly avoids triggering onNext+onError if cleanup fails (#1853)Mono#doOnTerminate
now acts similarly todoOnSuccess
, executing the side effect before theonNext
is propagated downstream (#1752)
- ๐
Mono#do[On|After]SuccessOrError
has been deprecated and marked for removal in 3.4 (#1854) - ๐
usingWhen
API has been polished, and some variants deprecated for removal in 3.4 (#1687)- A new overload has been introduced that uses
BiFunction
for error handler (exposing the failure that causes "rollback") - A single-handler version has been added to
Mono
for alignment withFlux
. This is the simplest case: same handler for complete, error and cancel terminations. - All other overloads have been deprecated. Goal is to favor either the simple 1-handler-covers-all case OR force users to be explicit about ALL possible terminations.
- A new overload has been introduced that uses
๐ฑ โจ New features and improvements
- Due to a few Throwable constants, class references could leak in multi-classloader environments. This is now avoided by skipping the filling of the stacktrace (#1872)
- โ Add BufferUntilChanged operator (#1706, bb5b2bb)
- โ Added new StepVerifier API to subscribe to source and verify it later (#1848, b2ce5fe)
๐ฑ ๐ Bug fixes
- (from 3.2:)
- ๐
Flux#flatMap
with scalar source now supports onErrorContinue (#1684) Flux#doAfterTerminate
now executed whenonError
in fused mode (#1836, #1835)- Explicitly catch
LinkageError
in Traces. This helps with some static analyzers (#1830) - ๐ Pass on
cancelSupport
when liftingConnectableFlux
(#1860)
๐ ๐ Documentation, Tests and Build
- [doc] Add limitRate marble diagrams (#1449)
- ๐ [build] Polish benchmarks build, remove jmh plugin (#1844, 1ba4944)
- โ๏ธ [doc] Fix several typos in javadocs (#1845)
- ๐ [build] Make it possible to run two JMH tasks - baseline and current (#1862)
- ๐ [polish] Fix MaterializeSubscriber toString, AbstractQueue's won't work (df34ad9)
- โก๏ธ [chores] Update BlockHound to RC1 (#1877)
- (from 3.2:)
- ๐ [github] Removed
CONTRIBUTING.md
and issue_template in favor of centralized ones (740c048) - ๐ [build] Use JCenter, not MavenCentral for doDownloadBaseline (aa08709, d4f5332)
- ๐ [doc] Remove double mention of subscribe in Flux README (#1861)
- 0๏ธโฃ [doc] Document that default initial delay for interval is the period (#1866)
๐ ๐ Thanks to the following contributors that also participated to this release
- A few Mono operators have slightly changed their behavior in regards to how when they propagate
-
v3.3.0.M3 Changes
July 30, 2019๐ Reactor-Core
3.3.0.M3
is part ofDysprosium-M3
Release Train.๐ This third milestone of the 3.3.x cycle contains bugfixes and improvements (including changes from the GA 3.2.11.RELEASE) as well as some behavior/API impacting changes:
โก๏ธ โ ๏ธ Update considerations and deprecations
- ๐ #1742 Processors and Kotlin extensions deprecations
- ๐ the
WorkQueueProcessor
andTopicProcessor
have been marked as deprecated for 3.3.x and will be removed in 3.4 - ๐ the Kotlin extensions are deprecated in core and replaced by a dedicated project/repo
- ๐ in both cases, the deprecated classes don't appear in the generated javadoc jar
- โฑ #1764 Deprecated method
Schedulers.Factory#decorateExecutorService
has been removed - #1669 All
onBackpressureBuffer(maxSize+error)
variants now delay errors - ๐ In debug mode, most of the original stacktrace is artificially moved at the end of the exception's output, after the "backtrace" (#1781)
- ๐ #1745
compose()
has been deprecated and renamedtransformDeferred()
- ๐ deprecated operator will be removed in 3.4
- ๐ฆ #1451 Dematerialize has been reworked and now expects 1 request per upstream
Signal
- ๐ฆ This avoids
onNext
events to be emitted only when the subsequent signal is ready upstream - ๐ฆ This also means that in order to get a terminal signal like
onComplete
signal, the correspondingSignal
must be explicitly requested from upstream (one extrarequest(1)
)
๐ฑ โจ New features and improvements
- โ Add "VirtualTimeScheduler#getScheduledTaskCount()" (#1746)
- #1763 Flux.parallel now uses
Schedulers.DEFAULT_POOL_SIZE
(which can be overridden by system property) - #1767 Add ParallelFlux#then to compose on parallel termination
- โฑ #1722 Make sure ElasticScheduler.CachedService gets disposed
- #1798 Use bounded wildcard in error(Supplier)
- ๐
Polish flux metrics (#1802)
- see also the other commits linked in that PR
- Actually record executor service metrics to Micrometer (#1795)
- โ Add a Context-aware {Mono,Flux}.deferWithContext (#1819)
- โก๏ธ Eliminate
subscribe
from stack by optimizing the "tail calls" (#1761, #1826) - #1416 Add lambda subscribe variants with a context
- (from 3.2:)
- #1793 Reject Context.of calls with duplicate keys
- ๐ Polish ContextN null checks (#1801)
๐ฑ ๐ Bug fixes
- (from 3.2:)
- โฑ #1739 Enforce a name for Schedulers.fromExecutorService
- without this explicit name, the metrics would use
null
as a name
- without this explicit name, the metrics would use
- ๐ #1783 Do not drop errors in MonoCacheTime, better doc (#1784)
- #1738 FluxRefCount inner doesn't guard against multiple cancels
- #1797 Explicitly reject null keys/values in Context constructors
- ๐ป #1741 MonoCreate hanging if delayUntil throws exception
๐ ๐ Documentation, Tests and Build
- ๐ [doc] Various documentation improvements and typo fixes (1847fcf, a7a25d3, 6289325, 631b399, #1757, #1796, #1820, #1821, d48ac6c)
- ๐ [build] Use "check" task as an aggregator, not "test" (#1776)
- ๐ [doc] #1539 Add "metrics" section to the reference guide (see also #1812, #1817)
- โก๏ธ Update BlockHound to 1.0.0.M4 (#1751)
- ๐ [chores] Polish codebase to fix compiler warnings/suppress some in tests (#1824)
๐ ๐ Thanks to the following contributors that also participated to this release
@jbnizet, @izeye, @dittos, @apuravchauhan, @gindex, @hisener, @berry120, @pcdavid, @ttddyy, @ramonPires