hunk.code_window: export default function publish() {
     return multicast.call(this, subjectFactory);
   }
  
hunk.labels: keep replace keep
hunk.after_edit:   return multicast.call(this, new Subject());
  
hunk.file_path: src/operators/publish.ts
hunk.type: replace
file: var RxOld = require('rx');
  var RxNew = require('../../../../index');
  
  module.exports = function (suite) {
    var oldTakeWithImmediateScheduler = RxOld.Observable.just(50, RxOld.Scheduler.immediate).take(5);
    var newTakeWithImmediateScheduler = RxNew.Observable.of(50).take(5);
  
    function _next(x) { }
    function _error(e) { }
    function _complete() { }
    return suite
        .add('old take with immediate scheduler', function () {
          oldTakeWithImmediateScheduler.subscribe(_next, _error, _complete);
        })
        .add('new take with immediate scheduler', function () {
          newTakeWithImmediateScheduler.subscribe(_next, _error, _complete);
        });
  };