<commit_before>import Rx from 'rxjs/Rx';

describe.only('rxjs', () => {

  it('observer.next(42)', (done) => {
    let publisher = Rx.Observable.create(observer => {
      observer.next(42);
      observer.complete();
    });

    publisher.subscribe(x => {
      console.log('  next resolves in success handler: ' + x);
      x.should.equal(42);
    },
    (error) => {
      console.error(error);
    },
    () => {
      console.info('  done resolves in complete handler');
      done();
    });
  });
});<commit_msg>refactor happy path<commit_after>import Rx from 'rxjs/Rx';

let separate = function() {
  console.log('');
  console.log('  __________________');
  console.log('');
};

describe.only('rxjs', () => {
  it('happy path: observer.next(42)', (done) => {
    separate();
    let publisher = Rx.Observable.create(observer => {
      observer.next(42);
      observer.complete();
    });

    publisher.subscribe(x => {
      console.log('    success handler called: ' + x);
      x.should.equal(42);
    },
    (error) => {
      console.info(error);
    },
    () => {
      console.info('    complete handler called');
      done();
    });
  });
});
{'fraction_non_alphanumeric': 0.19742489270386265, 'fraction_numerical': 0.010300429184549357, 'mean_word_length': 2.576687116564417, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 15, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '952392', 'n_tokens_mistral': 387, 'n_tokens_neox': 370, 'n_words': 67}