wip

Signed-off-by: Oleh Dokuka <[email protected]>
Signed-off-by: Oleh Dokuka <[email protected]>

Author: OlegDokuka

rsocket-core/src/main/java/io/rsocket/core/RSocketConnector.java

@@ -45,6 +45,8 @@
 import java.util.function.BiConsumer;
 import java.util.function.Consumer;
 import java.util.function.Supplier;
+
+import org.reactivestreams.Publisher;
 import reactor.core.Disposable;
 import reactor.core.publisher.Mono;
 import reactor.util.annotation.Nullable;
@@ -177,6 +179,11 @@ public RSocketConnector dataMimeType(String dataMimeType) {
     return this;
   }
 
+
+  public RSocketConnector gracefullShutdownTimeout(Supplier<? extends Publisher<?>> decider) {
+    decider.get().subscribe(() -> );
+  }
+
   /**
    * Set the MIME type to use for formatting payload metadata on the established connection. This is
    * set in the initial {@code SETUP} frame sent to the server.