function fixSubscriber(subscriber) {
      return subscriber && isFunction(subscriber.dispose) ? subscriber :
        isFunction(subscriber) ? disposableCreate(subscriber) : disposableEmpty;
    }
Executes a transducer to transform the observable sequence
@param {Transducer} transducer A transducer to execute
@returns {Observable} An Observable sequence containing the results from the transducer.