Added JDOCs for multiple classes. All tests pass. Addition towards is…

…sue #9

src/ConnectingMessageBuffer.js

@@ -1,12 +1,22 @@
 import {CLIENT_STATES} from './Constants';
 
 export default class ConnectingMessageBuffer {
+  /**
+   * Takes the client and drainCallback and creates an efficient buffer for buffering recieved messages.
+   * @param client
+   * @param drainCallback
+   */
   constructor(client, drainCallback) {
     this.buffer = [];
     this.client = client;
     this.drainCallback = drainCallback;
   }
 
+  /**
+   * Attempts to add a passed in message to the buffer.
+   * @param message
+   * @returns {boolean}
+   */
   tryBuffer(message) {
     if(this.client.state === CLIENT_STATES.connecting) {
       this.buffer.push(message);
@@ -15,6 +25,9 @@ export default class ConnectingMessageBuffer {
     return false;
   }
 
+  /**
+   * Drains the current buffer and removes all messages.
+   */
   drain() {
     // Ensure that the connection is connected when we drain (do not want to drain while a connection is not active)
     if(this.client.state === CLIENT_STATES.connected) {

src/EventEmitter.js

@@ -5,16 +5,25 @@ export default class EventEmitter {
     this.observers = {};
   }
 
+  /**
+   *Pushes an event to the passed in listener.
+   * @param event
+   * @param listener
+   */
   on(event, listener) {
     this.observers[event] = this.observers[event] || [];
     this.observers[event].push(listener);
   }
 
+  /**
+   * Removes an event from a passed in listener.
+   * @param event
+   * @param listener
+   */
   off(event, listener) {
     if (!this.observers[event]) {
       return;
     }
-
     this.observers[event].forEach(() => {
       if (! listener) {
         delete this.observers[event];
@@ -27,6 +36,11 @@ export default class EventEmitter {
     });
   }
 
+  /**
+   * Emits the passed in event to all observers.
+   * @param event
+   * @param args
+   */
   emit(event, ...args) {
     if (!this.observers[event]) {
       return;
@@ -35,6 +49,9 @@ export default class EventEmitter {
     this.observers[event].forEach(observer => observer(...args));
   }
 
+  /**
+   * Returns the true number of current observers.
+   */
   numberOfObservers() {
     return sum(this.observers, o => o.length);
   }