RxJS Subjet

Subjectの発火箇所と、発火後のロジックは分ける。

const rx = require('rxjs');
const op = require('rxjs/operators');

let sbj = getSubject()
sbj.next(1)
sbj.next(2)
sbj.complete()

function getSubject() {
  let sbj = new rx.Subject
  sbj.subscribe(cl)
  return sbj
}

function cl(v) {
  console.log(v)
}