Turn off suppressed exceptions (to squash)

Signed-off-by: Rossen Stoyanchev <[email protected]>
Use static errors in default RSocket methods

Closes gh-865

Signed-off-by: Rossen Stoyanchev <[email protected]>

Author: rstoyanchev

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

@@ -1,5 +1,5 @@
 /*
- * Copyright 2015-2018 the original author or authors.
+ * Copyright 2015-2020 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -34,8 +34,7 @@ public interface RSocket extends Availability, Closeable {
    *     handled, otherwise errors.
    */
   default Mono<Void> fireAndForget(Payload payload) {
-    payload.release();
-    return Mono.error(new UnsupportedOperationException("Fire-and-Forget not implemented."));
+    return RSocketAdapter.fireAndForget(payload);
   }
 
   /**
@@ -46,8 +45,7 @@ default Mono<Void> fireAndForget(Payload payload) {
    *     response.
    */
   default Mono<Payload> requestResponse(Payload payload) {
-    payload.release();
-    return Mono.error(new UnsupportedOperationException("Request-Response not implemented."));
+    return RSocketAdapter.requestResponse(payload);
   }
 
   /**
@@ -57,8 +55,7 @@ default Mono<Payload> requestResponse(Payload payload) {
    * @return {@code Publisher} containing the stream of {@code Payload}s representing the response.
    */
   default Flux<Payload> requestStream(Payload payload) {
-    payload.release();
-    return Flux.error(new UnsupportedOperationException("Request-Stream not implemented."));
+    return RSocketAdapter.requestStream(payload);
   }
 
   /**
@@ -68,7 +65,7 @@ default Flux<Payload> requestStream(Payload payload) {
    * @return Stream of response payloads.
    */
   default Flux<Payload> requestChannel(Publisher<Payload> payloads) {
-    return Flux.error(new UnsupportedOperationException("Request-Channel not implemented."));
+    return RSocketAdapter.requestChannel(payloads);
   }
 
   /**
@@ -79,8 +76,7 @@ default Flux<Payload> requestChannel(Publisher<Payload> payloads) {
    *     handled, otherwise errors.
    */
   default Mono<Void> metadataPush(Payload payload) {
-    payload.release();
-    return Mono.error(new UnsupportedOperationException("Metadata-Push not implemented."));
+    return RSocketAdapter.metadataPush(payload);
   }
 
   @Override

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

@@ -0,0 +1,78 @@
+/*
+ * Copyright 2015-2020 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package io.rsocket;
+
+import org.reactivestreams.Publisher;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+/**
+ * Package private class with default implementations for use in {@link RSocket}. The main purpose
+ * is to hide static {@link UnsupportedOperationException} declarations.
+ *
+ * @since 1.0.3
+ */
+class RSocketAdapter {
+
+  private static final Mono<Void> UNSUPPORTED_FIRE_AND_FORGET =
+      Mono.error(new UnsupportedInteractionException("Fire-and-Forget"));
+
+  private static final Mono<Payload> UNSUPPORTED_REQUEST_RESPONSE =
+      Mono.error(new UnsupportedInteractionException("Request-Response"));
+
+  private static final Flux<Payload> UNSUPPORTED_REQUEST_STREAM =
+      Flux.error(new UnsupportedInteractionException("Request-Stream"));
+
+  private static final Flux<Payload> UNSUPPORTED_REQUEST_CHANNEL =
+      Flux.error(new UnsupportedInteractionException("Request-Channel"));
+
+  private static final Mono<Void> UNSUPPORTED_METADATA_PUSH =
+      Mono.error(new UnsupportedInteractionException("Metadata-Push"));
+
+  static Mono<Void> fireAndForget(Payload payload) {
+    payload.release();
+    return RSocketAdapter.UNSUPPORTED_FIRE_AND_FORGET;
+  }
+
+  static Mono<Payload> requestResponse(Payload payload) {
+    payload.release();
+    return RSocketAdapter.UNSUPPORTED_REQUEST_RESPONSE;
+  }
+
+  static Flux<Payload> requestStream(Payload payload) {
+    payload.release();
+    return RSocketAdapter.UNSUPPORTED_REQUEST_STREAM;
+  }
+
+  static Flux<Payload> requestChannel(Publisher<Payload> payloads) {
+    return RSocketAdapter.UNSUPPORTED_REQUEST_CHANNEL;
+  }
+
+  static Mono<Void> metadataPush(Payload payload) {
+    payload.release();
+    return RSocketAdapter.UNSUPPORTED_METADATA_PUSH;
+  }
+
+  private static class UnsupportedInteractionException extends RuntimeException {
+
+    private static final long serialVersionUID = 5084623297446471999L;
+
+    UnsupportedInteractionException(String interactionName) {
+      super(interactionName + " not implemented.", null, false, false);
+    }
+  }
+}