Dariusz Jędrzejczyk
Dariusz Jędrzejczyk
Combining ConnectableFlux or Fuseable operators and wrapping via Hooks could lead to ClassCastException or lack of ThreadLocal restoration. ConnectableFlux and Fuseable handling has been improved. Also, lifting now avoids unnecessary...
This test failed on CI on 3.4.x branch: ``` Test class reactor.core.publisher.FluxReplayTest FluxBufferWhenTest > timedOutBuffersDontLeak() FAILED org.opentest4j.AssertionFailedError: [final GC collects all] expected: 400L but was: 321L at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at...
The following test failed during CI in 3.4.x ``` Gradle suite > Gradle test > reactor.core.publisher.tck.FluxBlackboxProcessorVerification > required_spec312_cancelMustMakeThePublisherToEventuallyStopSignaling FAILED java.lang.AssertionError: Publisher signalled [16] elements, which is more than the signalled...
This test is flaky. The duration is the same for both timers used and there inevitably will happen a race where the retry won't trigger but the attempt is still...
Sometimes this test freezes and is not even killed due to timeout. 3.4.37-SNAPSHOT JDK 8 Stack dump: ``` 2024-03-19 14:43:47 Full thread dump OpenJDK 64-Bit Server VM (25.352-b08 mixed mode):...
In current main, when reactor-core:3.7.0-SNAPSHOT is used, the following test fails: ``` reactor.kafka.receiver.internals.MockReceiverTest > consumerMethods FAILED java.lang.AssertionError: VerifySubscriber timed out on reactor.core.publisher.FluxLimitRequest$FluxLimitRequestSubscriber@6d87253e at reactor.test.MessageFormatter.assertionError(MessageFormatter.java:115) at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.pollTaskEventOrComplete(DefaultStepVerifierBuilder.java:1728) at reactor.test.DefaultStepVerifierBuilder$DefaultVerifySubscriber.verify(DefaultStepVerifierBuilder.java:1298) at reactor.test.DefaultStepVerifierBuilder$DefaultStepVerifier.verify(DefaultStepVerifierBuilder.java:832)...
In the latest round of architectural changes of Advisors in #1422 there now are two types of advisors: * `CallAroundAdvisor` * `StreamAroundAdvisor` In the case of the non-streaming one, it's...
### Describe the bug Hello, we are using the artifactory-gradle-plugin in reactor-core. We were stuck on JDK8 for a while and we used 4.33.1. Recently, we upgraded to a newer...