Adapt to more Reactor API changes

See gh-943

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

Author: rstoyanchev

Diff for: rsocket-core/src/main/java/io/rsocket/resume/ResumableDuplexConnection.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2015-2019 the original author or authors.
+ * Copyright 2015-2020 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -114,9 +114,9 @@ void initConnection(DuplexConnection nextConnection) {
             __ -> {
               frameReceivingSubscriber.dispose();
               disposable.dispose();
-              Sinks.Emission emission = onConnectionClosedSink.tryEmitNext(currentConnectionIndex);
-              if (emission.equals(Sinks.Emission.OK)) {
-                logger.error("Failed to notify session of closed connection: {}", emission);
+              Sinks.EmitResult result = onConnectionClosedSink.tryEmitNext(currentConnectionIndex);
+              if (result.equals(Sinks.EmitResult.OK)) {
+                logger.error("Failed to notify session of closed connection: {}", result);
               }
             })
         .subscribe();

Diff for: rsocket-examples/src/main/java/io/rsocket/examples/transport/tcp/fnf/TaskProcessingWithServerSideNotificationsExample.java

@@ -213,10 +213,10 @@ public RSocketTaskHandler(
       @Override
       public Mono<Void> fireAndForget(Payload payload) {
         logger.info("Received a Task[{}] from Client.ID[{}]", payload.getDataUtf8(), id);
-        Sinks.Emission emission = tasksToProcess.tryEmitNext(new Task(id, payload.getDataUtf8()));
+        Sinks.EmitResult result = tasksToProcess.tryEmitNext(new Task(id, payload.getDataUtf8()));
         payload.release();
-        return emission.hasFailed()
-            ? Mono.error(new Sinks.EmissionException(emission))
+        return result.isFailure()
+            ? Mono.error(new Sinks.EmissionException(result))
             : Mono.empty();
       }