Collapse most stream releated errors into IOError

2 files changed, 5 insertions, 5 deletions

diff --git a/xmpp-vala/src/module/message/module.vala b/xmpp-vala/src/module/message/module.vala
index 2eced5c1..bb63bca4 100644
--- a/xmpp-vala/src/module/message/module.vala
+++ b/xmpp-vala/src/module/message/module.vala
@@ -15,7 +15,7 @@ namespace Xmpp {
         public signal void received_error(XmppStream stream, MessageStanza message, ErrorStanza error);
         public signal void received_message_unprocessed(XmppStream stream, MessageStanza message);
 
-        public async void send_message(XmppStream stream, MessageStanza message) throws IOStreamError {
+        public async void send_message(XmppStream stream, MessageStanza message) throws IOError {
             yield send_pipeline.run(stream, message);
             yield stream.write_async(message.stanza);
         }
diff --git a/xmpp-vala/src/module/xep/0198_stream_management.vala b/xmpp-vala/src/module/xep/0198_stream_management.vala
index 5ce208f1..340c4e6f 100644
--- a/xmpp-vala/src/module/xep/0198_stream_management.vala
+++ b/xmpp-vala/src/module/xep/0198_stream_management.vala
@@ -25,7 +25,7 @@ public class Module : XmppStreamNegotiationModule, WriteNodeFunc {
         }
     }
 
-    public async void write_stanza(XmppStream stream, StanzaNode node) throws IOStreamError {
+    public async void write_stanza(XmppStream stream, StanzaNode node) throws IOError {
         var promise = new Promise<IOError?>();
 
         node_queue.add(new QueueItem(node, promise));
@@ -34,7 +34,7 @@ public class Module : XmppStreamNegotiationModule, WriteNodeFunc {
         try {
             yield promise.future.wait_async();
         } catch (FutureError e) {
-            throw new IOStreamError.WRITE("Future returned error %i".printf(e.code));
+            throw new IOError.FAILED("Future returned error %i".printf(e.code));
         }
     }
 
@@ -50,7 +50,7 @@ public class Module : XmppStreamNegotiationModule, WriteNodeFunc {
             } else {
                 yield ((!)writer).write_node(node);
             }
-        } catch (XmlError e) { }
+        } catch (IOError e) { }
     }
 
     private void check_queue(XmppStream stream) {
@@ -158,7 +158,7 @@ public class Module : XmppStreamNegotiationModule, WriteNodeFunc {
                         handle_incoming_h(stream, h_outbound);
                     }
                     foreach (var id in in_flight_stanzas.keys) {
-                        in_flight_stanzas[id].promise.set_exception(new IOStreamError.WRITE("Stanza not acked and session not resumed"));
+                        in_flight_stanzas[id].promise.set_exception(new IOError.FAILED("Stanza not acked and session not resumed"));
                     }
                     in_flight_stanzas.clear();
                     check_queue(stream);