hunk.code_window:     expect(subscriptions).toBe(1);
       done();
     });
     it('should allow you to reconnect by subscribing again', function (done) {
       var expected = [1, 2, 3, 4];
       var i = 0;
  
hunk.labels: keep keep keep keep replace keep keep keep
hunk.after_edit:   it('To match RxJS 4 behavior, it should NOT allow you to reconnect by subscribing again', function (done) {
  
hunk.file_path: spec/operators/publish-spec.js
hunk.type: replace
file: export default function throwError(e) { throw e; }
  