We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f9fb521 commit 870f25aCopy full SHA for 870f25a
1 file changed
rsocket-core/src/main/java/io/rsocket/core/RSocketConnector.java
@@ -45,6 +45,8 @@
45
import java.util.function.BiConsumer;
46
import java.util.function.Consumer;
47
import java.util.function.Supplier;
48
+
49
+import org.reactivestreams.Publisher;
50
import reactor.core.Disposable;
51
import reactor.core.publisher.Mono;
52
import reactor.util.annotation.Nullable;
@@ -177,6 +179,11 @@ public RSocketConnector dataMimeType(String dataMimeType) {
177
179
return this;
178
180
}
181
182
183
+ public RSocketConnector gracefullShutdownTimeout(Supplier<? extends Publisher<?>> decider) {
184
+ decider.get().subscribe(() -> );
185
+ }
186
187
/**
188
* Set the MIME type to use for formatting payload metadata on the established connection. This is
189
* set in the initial {@code SETUP} frame sent to the server.
0 commit comments