Detaillierte Erklärung von Observable (beobachtbares Objekt) in Angular

Dieser Artikel führt Sie durch Angular Observable. Es hat einen gewissen Referenzwert. Freunde in Not können sich darauf beziehen. Ich hoffe, es wird für alle hilfreich sein.

Empfohlene verwandte Tutorials: „angular Tutorial“

Beobachtbare Objekte (Observable)

Beobachtbare Objekte unterstützen die Übertragung von Nachrichten zwischen Herausgebern und Abonnenten einer Anwendung.

Observables sind deklarativ – das heißt, eine Funktion, die zum Veröffentlichen eines Werts definiert ist und erst dann tatsächlich ausgeführt wird, wenn ein Verbraucher ihn abonniert.

Drei Arten von Benachrichtigungen, die von Observablen ausgegeben werden können:

Beobachter definieren

Beobachter (Beobachter): Der Prozessor, der zum Empfangen von Benachrichtigungen von beobachtbaren Objekten verwendet wird, muss die Observer-Schnittstelle implementieren. Dieses Objekt definiert einige Rückruffunktionen zur Verarbeitung beobachtbarer Objekte Arten von Benachrichtigungen, die gesendet werden können.
Beobachterobjekte können jede Kombination dieser drei Prozessoren definieren. Wenn Sie für einen bestimmten Benachrichtigungstyp keinen Handler bereitstellen, ignoriert der Beobachter Benachrichtigungen dieses Typs.

// Create observer object
const myObserver = {
  next: (_data) => {
  	// next通知类型处理器
  },
  error: err => {
  	// error通知类型处理器
  },
  complete: () => console.log('Observer got a complete notification'),
};

Abonnement

Eine Observable-Instanz veröffentlicht einen Wert nur, wenn eine Instanz des Observable abonniert ist. Beim Abonnieren müssen Sie zunächst die Methode subscribe() der Instanz aufrufen und ihr ein Beobachterobjekt übergeben, um Benachrichtigungen zu erhalten.

Syntax: Observable.subscribe(ObserverObject), wobei Observable die beobachtbare Objektinstanz und ObserverObject das Beobachterobjekt ist. Observable.subscribe(ObserverObject)，其中，Observable为可观察对象实例，ObserverObject为观察者对象。

// 官网示例
// Create simple observable that emits three values
const myObservable = of(1, 2, 3);

// Create observer object
const myObserver = {
  next: x => console.log('Observer got a next value: ' + x),
  error: err => console.error('Observer got an error: ' + err),
  complete: () => console.log('Observer got a complete notification'),
};

// Execute with the observer object
myObservable.subscribe(myObserver);
// Logs:
// Observer got a next value: 1
// Observer got a next value: 2
// Observer got a next value: 3
// Observer got a complete notification

另外，subscribe() 方法还可以接收定义在同一行中的回调函数，无论 next、error 还是 complete 处理器。比如，下面的 subscribe() 调用和前面指定预定义观察者的例子是等价的。

myObservable.subscribe(
  x => console.log('Observer got a next value: ' + x),
  err => console.error('Observer got an error: ' + err),
  () => console.log('Observer got a complete notification')
);

注： 无论哪种情况，next通知类型的处理器是必要的，而error和complete处理器是可选的。

subscribe() 调用会返回一个 Subscription 对象，该对象具有一个 unsubscribe()rrreee

rrreee

Das obige ist der detaillierte Inhalt vonDetaillierte Erklärung von Observable (beobachtbares Objekt) in Angular. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!