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() {