Minor tweaks.

src/utils/FromIterable.js

@@ -7,7 +7,7 @@ class FromIterable extends Readable {
   static resolved = Promise.resolve();
 
   constructor(options) {
-    super(Object.assign({}, options, {objectMode: true}));
+    super(Object.assign({}, {objectMode: true}, options));
     const fn = options && options.iterable;
     if (typeof fn == 'function') {
       this._fn = fn;

src/utils/ReduceStream.js

@@ -7,7 +7,7 @@ const defaultReducer = (acc, value) => value;
 
 class ReduceStream extends Writable {
   constructor(options) {
-    super(Object.assign({}, options, {objectMode: true}));
+    super(Object.assign({}, {objectMode: true}, options));
     this.accumulator = defaultInitial;
     this._reducer = defaultReducer;
     if (options) {
@@ -31,7 +31,7 @@ class ReduceStream extends Writable {
     }
   }
   static make(reducer, initial) {
-    return new ReduceStream(typeof reducer == 'object' ? reducer : {reducer, initial});
+    return new ReduceStream(typeof reducer == 'object' && reducer.reducer ? reducer : {reducer, initial});
   }
 }
 ReduceStream.reduceStream = ReduceStream.make;