Switch to Reactor 2020.0.7 snapshots

See gh-1005

Signed-off-by: Rossen Stoyanchev <[email protected]>

Author: rstoyanchev

build.gradle

@@ -32,7 +32,7 @@ subprojects {
     apply plugin: 'io.spring.dependency-management'
     apply plugin: 'com.github.sherter.google-java-format'
 
-    ext['reactor-bom.version'] = '2020.0.4'
+    ext['reactor-bom.version'] = '2020.0.7-SNAPSHOT'
     ext['logback.version'] = '1.2.3'
     ext['netty-bom.version'] = '4.1.59.Final'
     ext['netty-boringssl.version'] = '2.0.36.Final'

rsocket-core/src/test/java/io/rsocket/core/ReconnectMonoTests.java

@@ -857,7 +857,7 @@ public void shouldExpireValueOnDispose() {
     Assertions.assertThat(received).hasSize(1);
     Assertions.assertThat(reconnectMono.isDisposed()).isTrue();
 
-    StepVerifier.create(reconnectMono.subscribeOn(Schedulers.elastic()))
+    StepVerifier.create(reconnectMono.subscribeOn(Schedulers.boundedElastic()))
         .expectSubscription()
         .expectError(CancellationException.class)
         .verify(Duration.ofSeconds(timeout));
@@ -923,7 +923,7 @@ public void shouldExpireValueExactlyOnceOnRacingBetweenInvalidates() {
       final ReconnectMono<String> reconnectMono =
           cold.mono().as(source -> new ReconnectMono<>(source, onExpire(), onValue()));
 
-      StepVerifier.create(reconnectMono.subscribeOn(Schedulers.elastic()))
+      StepVerifier.create(reconnectMono.subscribeOn(Schedulers.boundedElastic()))
           .expectSubscription()
           .expectNext("value")
           .expectComplete()
@@ -937,7 +937,7 @@ public void shouldExpireValueExactlyOnceOnRacingBetweenInvalidates() {
       Assertions.assertThat(expired).hasSize(1).containsOnly("value");
       Assertions.assertThat(received).hasSize(1).containsOnly(Tuples.of("value", reconnectMono));
 
-      StepVerifier.create(reconnectMono.subscribeOn(Schedulers.elastic()))
+      StepVerifier.create(reconnectMono.subscribeOn(Schedulers.boundedElastic()))
           .expectSubscription()
           .expectNext("value")
           .expectComplete()
@@ -965,7 +965,7 @@ public void shouldExpireValueExactlyOnceOnRacingBetweenInvalidateAndDispose() {
       final ReconnectMono<String> reconnectMono =
           cold.mono().as(source -> new ReconnectMono<>(source, onExpire(), onValue()));
 
-      StepVerifier.create(reconnectMono.subscribeOn(Schedulers.elastic()))
+      StepVerifier.create(reconnectMono.subscribeOn(Schedulers.boundedElastic()))
           .expectSubscription()
           .expectNext("value")
           .expectComplete()
@@ -979,7 +979,7 @@ public void shouldExpireValueExactlyOnceOnRacingBetweenInvalidateAndDispose() {
       Assertions.assertThat(expired).hasSize(1).containsOnly("value");
       Assertions.assertThat(received).hasSize(1).containsOnly(Tuples.of("value", reconnectMono));
 
-      StepVerifier.create(reconnectMono.subscribeOn(Schedulers.elastic()))
+      StepVerifier.create(reconnectMono.subscribeOn(Schedulers.boundedElastic()))
           .expectSubscription()
           .expectError(CancellationException.class)
           .verify(Duration.ofSeconds(timeout));
@@ -1011,7 +1011,7 @@ public void shouldTimeoutRetryWithVirtualTime() {
                             .maxBackoff(Duration.ofSeconds(maxBackoff)))
                     .timeout(Duration.ofSeconds(timeout))
                     .as(m -> new ReconnectMono<>(m, onExpire(), onValue()))
-                    .subscribeOn(Schedulers.elastic()))
+                    .subscribeOn(Schedulers.boundedElastic()))
         .expectSubscription()
         .thenAwait(Duration.ofSeconds(timeout))
         .expectError(TimeoutException.class)
@@ -1027,7 +1027,7 @@ public void ensuresThatMainSubscriberAllowsOnlyTerminationWithValue() {
     final ReconnectMono<String> reconnectMono =
         new ReconnectMono<>(Mono.empty(), onExpire(), onValue());
 
-    StepVerifier.create(reconnectMono.subscribeOn(Schedulers.elastic()))
+    StepVerifier.create(reconnectMono.subscribeOn(Schedulers.boundedElastic()))
         .expectSubscription()
         .expectErrorSatisfies(
             t ->