Subject

Subject 也是一种 Observable，但是具备数据的群发能力，可以被多个 Observer 订阅，并且还可以手动控制其中数据的发送。

import { from, Subject } from 'rxjs';
import { multicast } from 'rxjs/operators';

const source = from([1, 2, 3]);
const subject = new Subject();
const multicasted = source.pipe(multicast(subject));

multicasted.connect();