equal
deleted
inserted
replaced
671 Throwable initialCause = this.cause; |
671 Throwable initialCause = this.cause; |
672 if (initialCause == null) this.cause = t; |
672 if (initialCause == null) this.cause = t; |
673 client2.deleteConnection(this); |
673 client2.deleteConnection(this); |
674 List<Stream<?>> c = new LinkedList<>(streams.values()); |
674 List<Stream<?>> c = new LinkedList<>(streams.values()); |
675 for (Stream<?> s : c) { |
675 for (Stream<?> s : c) { |
676 s.connectionClosing(t); |
676 try { |
|
677 s.connectionClosing(t); |
|
678 } catch (Throwable e) { |
|
679 Log.logError("Failed to close stream {0}: {1}", s.streamid, e); |
|
680 } |
677 } |
681 } |
678 connection.close(); |
682 connection.close(); |
679 } |
683 } |
680 |
684 |
681 /** |
685 /** |