File tree Expand file tree Collapse file tree 3 files changed +14
-8
lines changed
rsocket-core/src/test/java/io/rsocket/core Expand file tree Collapse file tree 3 files changed +14
-8
lines changed Original file line number Diff line number Diff line change 1616
1717plugins {
1818 id ' com.github.sherter.google-java-format' version ' 0.8' apply false
19- id ' com.jfrog.artifactory' version ' 4.11.0 ' apply false
20- id ' com.jfrog.bintray' version ' 1.8.4 ' apply false
19+ id ' com.jfrog.artifactory' version ' 4.15.2 ' apply false
20+ id ' com.jfrog.bintray' version ' 1.8.5 ' apply false
2121 id ' me.champeau.gradle.jmh' version ' 0.5.0' apply false
22- id ' io.spring.dependency-management' version ' 1.0.8 .RELEASE' apply false
22+ id ' io.spring.dependency-management' version ' 1.0.9 .RELEASE' apply false
2323 id ' io.morethan.jmhreport' version ' 0.9.0' apply false
2424}
2525
2626subprojects {
2727 apply plugin : ' io.spring.dependency-management'
2828 apply plugin : ' com.github.sherter.google-java-format'
2929
30- ext[' reactor-bom.version' ] = ' Dysprosium-SR7 '
30+ ext[' reactor-bom.version' ] = ' Dysprosium-SR8 '
3131 ext[' logback.version' ] = ' 1.2.3'
3232 ext[' findbugs.version' ] = ' 3.0.2'
33- ext[' netty-bom.version' ] = ' 4.1.48 .Final'
33+ ext[' netty-bom.version' ] = ' 4.1.50 .Final'
3434 ext[' netty-boringssl.version' ] = ' 2.0.30.Final'
3535 ext[' hdrhistogram.version' ] = ' 2.1.10'
3636 ext[' mockito.version' ] = ' 3.2.0'
Original file line number Diff line number Diff line change 1+ # Mon Jun 08 20:22:21 EEST 2020
2+ distributionUrl =https\://services.gradle.org/distributions/gradle-6.5-all.zip
13distributionBase =GRADLE_USER_HOME
24distributionPath =wrapper/dists
3- distributionUrl =https\://services.gradle.org/distributions/gradle-6.3-bin.zip
4- zipStoreBase =GRADLE_USER_HOME
55zipStorePath =wrapper/dists
6+ zipStoreBase =GRADLE_USER_HOME
Original file line number Diff line number Diff line change @@ -468,7 +468,12 @@ public Flux<Payload> requestChannel(Publisher<Payload> payloads) {
468468 .assertTerminated ()
469469 .assertError (CancellationException .class )
470470 .assertErrorMessage ("Disposed" );
471- Assertions .assertThat (assertSubscriber .values ()).allMatch (ReferenceCounted ::release );
471+ Assertions .assertThat (assertSubscriber .values ())
472+ .allMatch (
473+ msg -> {
474+ ReferenceCountUtil .safeRelease (msg );
475+ return msg .refCnt () == 0 ;
476+ });
472477 rule .assertHasNoLeaks ();
473478 }
474479 }
You can’t perform that action at this time.
0 commit comments