From 956bc903a89f5a71b4aa98db2620b249968d7ca7 Mon Sep 17 00:00:00 2001 From: Oleh Dokuka Date: Mon, 28 Mar 2022 18:06:48 +0300 Subject: [PATCH] adds docs Signed-off-by: Oleh Dokuka Signed-off-by: Oleh Dokuka --- .../java/io/rsocket/core/FireAndForgetRequesterMono.java | 6 ++++++ .../java/io/rsocket/core/MetadataPushRequesterMono.java | 6 ++++++ 2 files changed, 12 insertions(+) diff --git a/rsocket-core/src/main/java/io/rsocket/core/FireAndForgetRequesterMono.java b/rsocket-core/src/main/java/io/rsocket/core/FireAndForgetRequesterMono.java index eceb0976c..12662489a 100644 --- a/rsocket-core/src/main/java/io/rsocket/core/FireAndForgetRequesterMono.java +++ b/rsocket-core/src/main/java/io/rsocket/core/FireAndForgetRequesterMono.java @@ -185,6 +185,12 @@ public Void block(Duration m) { return block(); } + + /** + * This method is deliberately non-blocking regardless it is named as `.block`. The + * main intent to keep this method along with the {@link #subscribe()} is to eliminate + * redundancy which comes with a default block method implementation. + */ @Override @Nullable public Void block() { diff --git a/rsocket-core/src/main/java/io/rsocket/core/MetadataPushRequesterMono.java b/rsocket-core/src/main/java/io/rsocket/core/MetadataPushRequesterMono.java index ffabe032e..d41e8cb7d 100644 --- a/rsocket-core/src/main/java/io/rsocket/core/MetadataPushRequesterMono.java +++ b/rsocket-core/src/main/java/io/rsocket/core/MetadataPushRequesterMono.java @@ -120,6 +120,12 @@ public Void block(Duration m) { return block(); } + + /** + * This method is deliberately non-blocking regardless it is named as `.block`. The + * main intent to keep this method along with the {@link #subscribe()} is to eliminate + * redundancy which comes with a default block method implementation. + */ @Override @Nullable public Void block() {