File tree Expand file tree Collapse file tree 2 files changed +12
-0
lines changed
rsocket-core/src/main/java/io/rsocket/core Expand file tree Collapse file tree 2 files changed +12
-0
lines changed Original file line number Diff line number Diff line change @@ -185,6 +185,12 @@ public Void block(Duration m) {
185185 return block ();
186186 }
187187
188+
189+ /**
190+ * This method is deliberately non-blocking regardless it is named as `.block`. The
191+ * main intent to keep this method along with the {@link #subscribe()} is to eliminate
192+ * redundancy which comes with a default block method implementation.
193+ */
188194 @ Override
189195 @ Nullable
190196 public Void block () {
Original file line number Diff line number Diff line change @@ -120,6 +120,12 @@ public Void block(Duration m) {
120120 return block ();
121121 }
122122
123+
124+ /**
125+ * This method is deliberately non-blocking regardless it is named as `.block`. The
126+ * main intent to keep this method along with the {@link #subscribe()} is to eliminate
127+ * redundancy which comes with a default block method implementation.
128+ */
123129 @ Override
124130 @ Nullable
125131 public Void block () {
You can’t perform that action at this time.
0 commit comments