RxJS - 釋出多播運算子

publish() 運算子返回 ConnectableObservable，需要使用 connect() 方法來訂閱該可觀察物件。

語法

publish()

示例

import { interval,Observable } from 'rxjs';
import { filter, publish } from 'rxjs/operators';
var observable = new Observable(function subscribe(subscriber) {
   try {
      subscriber.next(Math.random());
   } catch (e) {
      subscriber.error(e);
   }
});

const observable1 = publish()(observable);
const subscribe_one = observable1.subscribe(
   x => console.log("Value from Sub1 = "+x)
);
const subscribe_two = observable1.subscribe(
   x => console.log("Value from Sub2 = "+x)
);
observable1.connect();

輸出