some improvements.. might be broken right now

Author: nfriedly

dist/watson-speech.js

@@ -14,6 +14,7 @@ var clone = require('clone');
  * @param opts
  * @param opts.model - some models / languages need special handling
  * @param [opts.hesitation='\u2026'] - what to put down for a "hesitation" event, defaults to an ellipsis (...)
+ * @param {Boolean} [options.objectMode=false] - emit `result` objects instead of string Buffers for the `data` events.
  * @constructor
  */
 function FormatStream(opts) {

speech-to-text/format-stream.js

@@ -54,7 +54,7 @@ var QUERY_PARAMS_ALLOWED = ['model', 'watson-token']; //, 'X-Watson-Learning-Opt
  * @constructor
  */
 function RecognizeStream(options) {
-  Duplex.call(this, {readableObjectMode: options && (options.objectMode)});
+  Duplex.call(this, {readableObjectMode: options && (options.objectMode || options.readableObjectMode)});
   this.options = options;
   this.listening = false;
   this.initialized = false;
@@ -223,9 +223,9 @@ RecognizeStream.prototype.initialize = function () {
            * @param {String} transcript
            */
           if (options.objectMode) {
-            self.push(result); // this is the "data" event that can be easily piped to other streams
+            self.push(result);
           } else {
-            self.push(result.alternatives[0].transcript, 'utf8'); // this is the "data" event that can be easily piped to other streams
+            self.push(result.alternatives[0].transcript, 'utf8');
           }
 
         }

speech-to-text/recognize-stream.js

@@ -12,13 +12,15 @@ var clone = require('clone');
  * @param {Object} opts
  * @param {*} [opts.emitAtt=TimingStream.START] - set to TimingStream.END to only emit text that has been completely spoken.
  * @param {Number} [opts.delay=0] - Additional delay (in seconds) to apply before emitting words, useful for precise syncing to audio tracks. May be negative
+ * @param {Boolean} [options.objectMode=false] - emit `result` objects instead of string Buffers for the `data` events.
  * @constructor
  */
 function TimingStream(opts) {
   this.opts = util._extend({
     emitAt: TimingStream.START,
     delay: 0,
-    allowHalfOpen: true // keep the readable side open after the source closes
+    allowHalfOpen: true, // keep the readable side open after the source closes
+    objectMode: false
   }, opts);
   Duplex.call(this, opts);