Added sender_flow and receiver_flow events based on this issue comment #74 (comment)

Author: amarzavery

lib/eventTypes.js

@@ -32,6 +32,10 @@ var ReceiverEvents;
      * are no more messages at present that it can send).
      */
     ReceiverEvents['receiverDrained'] = 'receiver_drained';
+    /**
+     * @property {string} receiverFlow Raised when a flow is received for receiver.
+     */
+    ReceiverEvents['receiverFlow'] = 'receiver_flow';
     /**
      * @property {string} receiverError Raised when the remote peer
      * closes the receiver with an error. The context may also have an
@@ -68,6 +72,10 @@ var SenderEvents;
      * is used up..
      */
     SenderEvents['senderDraining'] = 'sender_draining';
+    /**
+     * @property {string} senderFlow Raised when a flow is received for sender.
+     */
+    SenderEvents['senderFlow'] = 'sender_flow';
     /**
      * @property {string} senderError Raised when the remote peer
      * closes the sender with an error. The context may also have an
@@ -139,6 +147,14 @@ var ConnectionEvents;
      * the connection.
      */
     ConnectionEvents['connectionError'] = 'connection_error';
+    /**
+     * @property {string} protocolError Raised when a protocol error is received on the underlying socket.
+     */
+    ConnectionEvents['protocolError'] = 'protocol_error',
+    /**
+     * @property {string} error Raised when an error is received on the underlying socket.
+     */
+    ConnectionEvents['error'] = 'error',
     /**
      * @property {string} disconnected Raised when the underlying tcp connection is lost. The context
      * has a reconnecting property which is true if the library is attempting to automatically reconnect

test/eventTypes.ts

@@ -22,6 +22,7 @@ describe('event types', function() {
         assert.equal(rhea.ReceiverEvents.message, "message");
         assert.equal(rhea.ReceiverEvents.receiverClose, "receiver_close");
         assert.equal(rhea.ReceiverEvents.receiverDrained, "receiver_drained");
+        assert.equal(rhea.ReceiverEvents.receiverFlow, "receiver_flow");
         assert.equal(rhea.ReceiverEvents.receiverError, "receiver_error");
         assert.equal(rhea.ReceiverEvents.receiverOpen, "receiver_open");
         assert.equal(rhea.ReceiverEvents.settled, "settled");
@@ -33,6 +34,7 @@ describe('event types', function() {
         assert.equal(rhea.SenderEvents.released, "released");
         assert.equal(rhea.SenderEvents.modified, "modified");
         assert.equal(rhea.SenderEvents.senderDraining, "sender_draining");
+        assert.equal(rhea.SenderEvents.senderFlow, "sender_flow");
         assert.equal(rhea.SenderEvents.sendable, "sendable");
         assert.equal(rhea.SenderEvents.senderClose, "sender_close");
         assert.equal(rhea.SenderEvents.senderError, "sender_error");
@@ -52,6 +54,8 @@ describe('event types', function() {
         assert.equal(rhea.ConnectionEvents.connectionClose, "connection_close");
         assert.equal(rhea.ConnectionEvents.connectionError, "connection_error");
         assert.equal(rhea.ConnectionEvents.connectionOpen, "connection_open");
+        assert.equal(rhea.ConnectionEvents.protocolError, "protocol_error");
+        assert.equal(rhea.ConnectionEvents.error, "error");
         assert.equal(rhea.ConnectionEvents.disconnected, "disconnected");
         assert.equal(rhea.ConnectionEvents.settled, "settled");
         done();

typings/connection.d.ts

@@ -570,6 +570,14 @@ export declare enum ConnectionEvents {
    * the connection.
    */
   connectionError = "connection_error",
+  /**
+   * @property {string} protocolError Raised when a protocol error is received on the underlying socket.
+   */
+  protocolError = "protocol_error",
+  /**
+   * @property {string} error Raised when an error is received on the underlying socket.
+   */
+  error = "error",
   /**
    * @property {string} disconnected Raised when the underlying tcp connection is lost. The context
    * has a reconnecting property which is true if the library is attempting to automatically reconnect

typings/link.d.ts

@@ -90,6 +90,10 @@ export declare enum ReceiverEvents {
    * are no more messages at present that it can send).
    */
   receiverDrained  = 'receiver_drained',
+  /**
+   * @property {string} receiverFlow Raised when a flow is received for receiver.
+   */
+  receiverFlow = "receiver_flow",
   /**
    * @property {string} receiverError Raised when the remote peer closes the receiver with an
    * error. The context may also have an error property giving some information about the reason
@@ -124,6 +128,10 @@ export declare enum SenderEvents {
    * is used up..
    */
   senderDraining = 'sender_draining',
+  /**
+   * @property {string} senderFlow Raised when a flow is received for sender.
+   */
+  senderFlow = "sender_flow",
   /**
    * @property {string} senderError Raised when the remote peer closes the sender with an
    * error. The context may also have an error property giving some information about the