Upgrade to Reactor Dysprosium (rsocket#671)

rstoyanchev · robertroeser · commit c49cbd7c4820 · 2019-07-25T12:57:26.000-07:00
Closes rsocketgh-670 Signed-off-by: Rossen Stoyanchev <rstoyanchev@pivotal.io>
diff --git a/build.gradle b/build.gradle
@@ -29,10 +29,10 @@ subprojects {
     apply plugin: 'io.spring.dependency-management'
     apply plugin: 'com.github.sherter.google-java-format'
 
-    ext['reactor-bom.version'] = 'Californium-SR8'
+    ext['reactor-bom.version'] = 'Dysprosium-M2'
     ext['logback.version'] = '1.2.3'
     ext['findbugs.version'] = '3.0.2'
-    ext['netty.version'] = '4.1.36.Final'
+    ext['netty.version'] = '4.1.37.Final'
     ext['netty-boringssl.version'] = '2.0.25.Final'
     ext['hdrhistogram.version'] = '2.1.10'
     ext['mockito.version'] = '2.25.1'
@@ -89,6 +89,7 @@ subprojects {
 
     repositories {
         mavenCentral()
+        maven { url 'http://repo.spring.io/milestone' } // temporary for Reactor Dysprosium
 
         if (version.endsWith('BUILD-SNAPSHOT') || project.hasProperty('platformVersion')) {
             maven { url 'http://repo.spring.io/libs-snapshot' }
diff --git a/rsocket-core/src/main/java/io/rsocket/internal/UnicastMonoProcessor.java b/rsocket-core/src/main/java/io/rsocket/internal/UnicastMonoProcessor.java
@@ -2,7 +2,6 @@
 
 import java.util.Objects;
 import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
-import java.util.function.LongSupplier;
 import java.util.stream.Stream;
 import org.reactivestreams.Processor;
 import org.reactivestreams.Subscription;
@@ -17,12 +16,7 @@
 import reactor.util.function.Tuple2;
 
 public class UnicastMonoProcessor<O> extends Mono<O>
-    implements Processor<O, O>,
-        CoreSubscriber<O>,
-        Disposable,
-        Subscription,
-        Scannable,
-        LongSupplier {
+    implements Processor<O, O>, CoreSubscriber<O>, Disposable, Subscription, Scannable {
 
   @SuppressWarnings("rawtypes")
   static final AtomicIntegerFieldUpdater<UnicastMonoProcessor> ONCE =
@@ -87,11 +81,6 @@ public Stream<Tuple2<String, String>> tags() {
     return processor.tags();
   }
 
-  @Override
-  public long getAsLong() {
-    return processor.getAsLong();
-  }
-
   @Override
   public void onSubscribe(Subscription s) {
     processor.onSubscribe(s);
