Update Netty error wrapping

reactor · May 9, 2019 · 5ee6151 · 5ee6151
1 parent 5059f86
commit 5ee6151
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 16 deletions.
diff --git a/src/main/java/reactor/netty/ReactorNetty.java b/src/main/java/reactor/netty/ReactorNetty.java
@@ -168,7 +168,7 @@ public static String format(Channel channel, String msg) {
 	 * @return a wrapped {@link RuntimeException}
 	 */
 	public static RuntimeException wrapException(Throwable throwable) {
-		return new ReactorNettyException(Objects.requireNonNull(throwable));
+		return new InternalNettyException(Objects.requireNonNull(throwable));
 	}
 
 	static void addChunkedWriter(Connection c){
@@ -765,15 +765,15 @@ public Mono<Void> then() {
 		};
 	}
 
-	static final class ReactorNettyException extends RuntimeException {
+	static final class InternalNettyException extends RuntimeException {
 
-		ReactorNettyException(Throwable cause) {
+		InternalNettyException(Throwable cause) {
 			super(cause);
 		}
 
 		@Override
 		public synchronized Throwable fillInStackTrace() {
-			return getCause().fillInStackTrace();
+			return this;
 		}
 	}
 

diff --git a/src/main/java/reactor/netty/channel/AbortedException.java b/src/main/java/reactor/netty/channel/AbortedException.java
@@ -31,10 +31,6 @@ public AbortedException(String message) {
 		super(message);
 	}
 
-	public AbortedException(Throwable cause) {
-		super(cause);
-	}
-
 	/**
 	 * Return true if connection has been simply aborted on a tcp level by verifying if
 	 * the given inbound error.
@@ -54,12 +50,4 @@ public static boolean isConnectionReset(Throwable err) {
 		                                          err.getMessage()
 		                                             .contains("Connection reset by peer"));
 	}
-
-	@Override
-	public synchronized Throwable fillInStackTrace() {
-		if (getCause() != null) {
-			return getCause().fillInStackTrace();
-		}
-		return this;
-	}
 }