Merge pull request #47 from vanniktech/cause

Add cause to ConnectionClosedException.
IvBaranov · Oct 29, 2018 · 94a4533 · 94a4533
2 parents 782e3de + 63add7d
commit 94a4533
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 7 deletions.
diff --git a/rxbluetooth/src/main/java/com/github/ivbaranov/rxbluetooth/BluetoothConnection.java b/rxbluetooth/src/main/java/com/github/ivbaranov/rxbluetooth/BluetoothConnection.java
@@ -87,7 +87,7 @@ public Flowable<Byte> observeByteStream() {
               subscriber.onNext((byte) inputStream.read());
             } catch (IOException e) {
               connected = false;
-              subscriber.onError(new ConnectionClosedException("Can't read stream"));
+              subscriber.onError(new ConnectionClosedException("Can't read stream", e));
             } finally {
               if (!connected) {
                 closeConnection();

diff --git a/.../src/main/java/com/github/ivbaranov/rxbluetooth/exceptions/ConnectionClosedException.java b/.../src/main/java/com/github/ivbaranov/rxbluetooth/exceptions/ConnectionClosedException.java
@@ -19,11 +19,7 @@
 
 public final class ConnectionClosedException extends IOException {
 
-  public ConnectionClosedException() {
-    super("Connection is closed.");
-  }
-
-  public ConnectionClosedException(String message) {
-    super(message);
+  public ConnectionClosedException(String message, Throwable cause) {
+    super(message, cause);
   }
 }