Implement error handling

src/channel/channel.ts

@@ -32,9 +32,14 @@ export abstract class Channel {
  abstract stopListening(event: string): Channel;
 
  /**
- * Stop listening for a whispser event on the channel instance.
+ * Stop listening for a whisper event on the channel instance.
  */
  stopListeningForWhisper(event: string): Channel {
  return this.stopListening('.client-' + event);
  }
+
+ /**
+ * Register a callback to be called anytime an error occurs.
+ */
+ abstract error(callback: Function): Channel;
 }

src/channel/null-channel.ts

@@ -32,6 +32,13 @@ export class NullChannel extends Channel {
  return this;
  }
 
+ /**
+ * Register a callback to be called anytime an error occurs.
+ */
+ error(callback: Function): NullChannel {
+ return this;
+ }
+
  /**
  * Bind a channel to an event.
  */

src/channel/pusher-channel.ts

@@ -1,4 +1,4 @@
-import { EventFormatter } from './../util';
+import { EventFormatter } from '../util';
 import { Channel } from './channel';
 
 /**
@@ -76,6 +76,17 @@ export class PusherChannel extends Channel {
  return this;
  }
 
+ /**
+ * Register a callback to be called anytime a subscription error occurs.
+ */
+ error(callback: Function): PusherChannel {
+ this.on('pusher:subscription_error', (status) => {
+ callback(status);
+ });
+
+ return this;
+ }
+
  /**
  * Bind a channel to an event.
  */

src/channel/socketio-channel.ts

@@ -1,4 +1,4 @@
-import { EventFormatter } from './../util';
+import { EventFormatter } from '../util';
 import { Channel } from './channel';
 
 /**
@@ -87,6 +87,13 @@ export class SocketIoChannel extends Channel {
  return this;
  }
 
+ /**
+ * Register a callback to be called anytime an error occurs.
+ */
+ error(callback: Function): SocketIoChannel {
+ return this;
+ }
+
  /**
  * Bind the channel's socket to an event and store the callback.
  */