RxJS materialize

將來自源的所有通知表示為 Observable，next 將其標記為Notification 對象中原始類型的排放。

materialize<T>(): OperatorFunction<T, Notification<T>>

參量

沒有參數(shù)。

returns

OperatorFunction<T, Notification<T>>：一個 Observable 發(fā)出 Notification對象，該對象包裝帶有源數(shù)據(jù)的原始 Observable 的元數(shù)據(jù)。

描述

包裹物next，error并且complete排放 Notification的目的，發(fā)射為next在輸出觀察到。

materialize返回可觀察到的發(fā)射一個next為每個通知 next，error或complete源可觀察的發(fā)射。當(dāng)源 Observable 發(fā)出時complete，輸出 Observable 將next作為類型為“ complete” 的 Notification 發(fā)出，然后也將發(fā)出complete。當(dāng)源 Observable 發(fā)出時error，輸出將發(fā)出next“錯誤”類型的通知，然后發(fā)出complete。

該運算符對于生成可觀察源的元數(shù)據(jù)很有用，將其作為next排放量消耗。與結(jié)合使用 dematerialize。

例

將錯誤的可觀察者轉(zhuǎn)換為可觀察者通知

import { of } from 'rxjs';
import { materialize, map } from 'rxjs/operators';


const letters = of('a', 'b', 13, 'd');
const upperCase = letters.pipe(map(x => x.toUpperCase()));
const materialized = upperCase.pipe(materialize());
materialized.subscribe(x => console.log(x));


// Results in the following:
// - Notification {kind: "N", value: "A", error: undefined, hasValue: true}
// - Notification {kind: "N", value: "B", error: undefined, hasValue: true}
// - Notification {kind: "E", value: undefined, error: TypeError:
//   x.toUpperCase is not a function at MapSubscriber.letters.map.x
//   [as project] (http://1…, hasValue: false}

也可以看看

• Notification
• dematerialize