Merge pull request #18 from kushan-chinthaka/fb_issue17

Two fixes: propagate errors from recognizeStream to whatever stream is returned to the user, and only send data on open websockets

Fixes #17 
Fixes #10

Author: nfriedly

speech-to-text/recognize-microphone.js

@@ -141,6 +141,17 @@ module.exports = function recognizeMicrophone(options) {
 
   }).catch(recognizeStream.emit.bind(recognizeStream, 'error'));
 
+  /**
+   * Propagate error to new FormatStream
+   *
+   * @param {String} error message
+   */
+  function handleError(error) {
+    stream.emit('error', error);
+  }
+
+  // Capture error from original RecognizeStream
+  recognizeStream.on('error', handleError);
 
   return stream;
 };

speech-to-text/recognize-stream.js

@@ -404,7 +404,7 @@ RecognizeStream.prototype.finish = function finish() {
   this.finished = true;
   var self = this;
   var closingMessage = {action: 'stop'};
-  if (self.socket && self.socket.readyState !== self.socket.CLOSED && self.socket.readyState !== self.socket.CLOSING) {
+  if (self.socket && self.socket.readyState === self.socket.OPEN) {
     self.sendJSON(closingMessage);
   } else {
     this.once('connect', function() {