RxJS - Operatoren

Dieser Operator stellt eine Ajax-Anfrage für die angegebene URL.

Dieser Operator erstellt ein Observable aus einem Array, einem Array-ähnlichen Objekt, einem Versprechen, einem iterierbaren Objekt oder einem Observable-ähnlichen Objekt.

Dieser Operator gibt eine Ausgabe als Observable aus, die für Elemente verwendet werden soll, die ein Ereignis auslösen, z. B. Schaltflächen, Klicks usw.

Dieser Operator erstellt aus der Eingabefunktion eine Observable, mit der Ereignishandler registriert werden.

Dieser Operator erstellt für jedes Mal ein Observable für die angegebene Zeit.

Dieser Operator nimmt die übergebenen Argumente auf und konvertiert sie in Observable.

Dieser Operator erstellt ein Observable, das Ihnen eine Folge von Zahlen basierend auf dem angegebenen Bereich gibt.

Dieser Operator erstellt eine Observable, die einen Fehler meldet.

Dieser Operator erstellt eine Observable, die den Wert nach dem Timeout ausgibt und nach jedem Aufruf weiter ansteigt.

Dieser Betreiber entscheidet, welches Observable abonniert wird.

Der Operator count () nimmt eine Observable mit Werten auf und konvertiert sie in eine Observable, die einen einzelnen Wert ergibt

Die Max-Methode nimmt eine Observable mit allen Werten auf und gibt eine Observable mit dem Max-Wert zurück

Die Min-Methode nimmt eine Observable mit allen Werten auf und gibt eine Observable mit dem Min-Wert zurück.

Beim Reduzieren des Operators wird die Akkumulatorfunktion für die beobachtbare Eingabe verwendet, und die Akkumulatorfunktion gibt den akkumulierten Wert in Form einer beobachtbaren Funktion zurück, wobei ein optionaler Startwert an die Akkumulatorfunktion übergeben wird.

Die Funktion redu () akzeptiert 2 Argumente, eine Akkumulatorfunktion und den zweiten den Startwert.

Dieser Operator gibt nacheinander das als Eingabe angegebene Observable aus und fährt mit dem nächsten fort.

Dieser Operator wird in einem Array oder Diktierobjekt als Eingabe verwendet und wartet, bis die Observable abgeschlossen ist, und gibt die letzten von der angegebenen Observable ausgegebenen Werte zurück.

Dieser Operator nimmt die beobachtbare Eingabe auf und gibt alle Werte aus der beobachtbaren und eine einzige beobachtbare Ausgabe aus.

Es wird ein Observable zurückgegeben, das eine Spiegelkopie der ersten beobachtbaren Quelle ist.

Der Puffer arbeitet mit einem Observable und nimmt das Argument als Observable auf. Es beginnt mit dem Puffern der Werte, die auf seinem ursprünglichen Observable in einem Array ausgegeben werden, und gibt dasselbe aus, wenn das als Argument genommene Observable ausgegeben wird. Sobald das als Argumente verwendete Observable ausgegeben wird, wird der Puffer zurückgesetzt und beginnt erneut mit dem Puffern auf dem Original, bis das eingegebene Observable ausgegeben wird und dasselbe Szenario wiederholt wird.

Im Fall des Operators buffercount () sammelt er die Werte aus dem Observable, auf dem er aufgerufen wird, und gibt dieselben aus, wenn die Puffergröße für buffercount übereinstimmt.

Dies ist ähnlich wie bei bufferCount, daher werden hier die Werte aus dem Observable gesammelt, auf dem es aufgerufen wird, und der BufferTimeSpan wird ausgegeben. Es nimmt 1 Argument an, dh bufferTimeSpan .

Im Fall von bufferToggle () werden 2 Argumente benötigt, openings und closeSelector. Die Eröffnungsargumente sind abonnierbar oder versprechen, den Puffer zu starten, und das zweite Argument schließtSelector ist wieder abonnierbar oder verspricht einen Indikator zum Schließen des Puffers und zum Ausgeben der gesammelten Werte.

Dieser Operator gibt die Werte in der Array-Form an. Er verwendet ein Argument als Funktion, die entscheidet, wann der Puffer geschlossen, ausgegeben und zurückgesetzt werden soll.

Der Operator expand nimmt eine Funktion als Argument auf, die rekursiv auf die beobachtbare Quelle und auch auf die beobachtbare Ausgabe angewendet wird. Der Endwert ist ein beobachtbarer Wert.

Im groupBy-Operator wird die Ausgabe basierend auf einer bestimmten Bedingung gruppiert und diese Gruppenelemente werden als GroupedObservable ausgegeben.

Im Fall eines Kartenoperators wird eine Projektfunktion auf jeden Wert in der Quelle Observable angewendet und dieselbe Ausgabe wird als Observable ausgegeben.

Jedes Mal, wenn die Quelle Observable einen Wert ausgibt, wird zusammen mit dem Observable ein konstanter Wert als Ausgabe angegeben.

Im Fall des Operators mergeMap wird auf jeden Quellwert eine Projektfunktion angewendet und die Ausgabe davon mit der Ausgabe Observable zusammengeführt.

Im Fall des switchMap-Operators wird auf jeden Quellwert eine Projektfunktion angewendet, und die Ausgabe davon wird mit der Ausgabe Observable zusammengeführt, und der angegebene Wert ist der zuletzt projizierte Observable.

Es wird ein Argument für Fenstergrenzen verwendet, das beobachtbar ist, und es wird ein verschachteltes beobachtbares Element zurückgegeben, wenn die angegebenen Fenstergrenzen ausgegeben werden

Ein Wert, der nach einer Weile von der beobachtbaren Quelle abgegeben wird, und die Emission wird durch eine andere Eingabe bestimmt, die als beobachtbar oder versprochen angegeben wird.

Es wird einen Wert von der Quelle ausgeben, der erst nach Ablauf der Zeit beobachtet werden kann.

Dieser Operator gibt alle Werte aus der beobachtbaren Quelle an, die sich im Vergleich zum vorherigen Wert unterscheiden.

Dieser Operator gibt einen einzelnen Wert aus der beobachtbaren Quelle basierend auf dem angegebenen Index an.

Dieser Operator filtert die Werte aus der Quelle Observable basierend auf der angegebenen Prädikatfunktion.

Dieser Operator gibt den ersten Wert an, der von der Quelle Observable ausgegeben wird.

Dieser Operator gibt den letzten von der Quelle Observable ausgegebenen Wert an.

Dieser Operator ignoriert alle Werte aus der Quelle Observable und führt nur Aufrufe aus, um Rückruffunktionen abzuschließen oder Fehler zu machen.

Dieser Operator gibt den neuesten Wert aus der Quelle Observable an, und die Ausgabe hängt von dem Argument ab, das an ihn ausgegeben wird.

Dieser Operator gibt ein Observable zurück, das das erste Auftreten von Zählelementen überspringt, die als Eingabe verwendet werden.

Dieser Operator gibt Werte aus der Quelle aus und ignoriert sie, die für die Zeit beobachtet werden können, die durch die als Argument verwendete Eingabefunktion bestimmt wird, und der gleiche Vorgang wird wiederholt.

Dieser Operator hat die gleiche Ausgabe wie die beobachtbare Quelle und kann verwendet werden, um die Werte aus der beobachtbaren Datei an den Benutzer zu protokollieren. Der Hauptwert, Fehler, falls vorhanden oder wenn die Aufgabe abgeschlossen ist.

Dieser Operator verzögert die von der beobachtbaren Quelle ausgegebenen Werte basierend auf dem angegebenen Zeitlimit.

Dieser Operator verzögert die von der Quelle Observable ausgegebenen Werte basierend auf dem Timeout einer anderen als Eingabe genommenen Observable.

Dieser auf dem Eingabeplaner basierende Operator gibt die Benachrichtigungen von der Quelle Observable erneut aus.

Dieser Operator hilft beim asynchronen Abonnieren der Quelle Observable basierend auf dem als Eingabe verwendeten Scheduler.

Dieser Operator gibt ein Objekt zurück, das den aktuellen Wert und die zwischen dem aktuellen und dem vorherigen Wert verstrichene Zeit enthält, die mithilfe der Scheduler-Eingabe berechnet wurden.

Gibt den Zeitstempel zusammen mit dem von source Observable ausgegebenen Wert zurück, der den Zeitpunkt angibt, zu dem der Wert ausgegeben wurde.

Dieser Operator gibt einen Fehler aus, wenn die Quelle Observable nach dem angegebenen Zeitlimit keinen Wert ausgibt.

Sammelt den gesamten Quellwert aus dem Observable und gibt ihn nach Abschluss der Quelle als Array aus.

Dieser Operator gibt einen Standardwert zurück, wenn die beobachtbare Quelle leer ist.

Es wird ein Observable zurückgegeben, das auf der Eingabefunktion basiert und die Bedingung für jeden Wert auf Source Observable erfüllt.

Dies gibt das Observable zurück, wenn der erste Wert des Source Observable die Bedingung für die als Eingabe verwendete Prädikatfunktion erfüllt.

Dieser auf dem Eingabeplaner basierende Operator gibt die Benachrichtigungen von der Quelle Observable erneut aus.

Dieser Operator gibt die Ausgabe als wahr aus, wenn die beobachtbare Eingabe einen vollständigen Rückruf ohne Ausgabe von Werten ermöglicht, und als falsch, wenn die beobachtbare Eingabe Werte ausgibt.

Ein Multicast-Betreiber teilt das erstellte Einzelabonnement mit anderen Abonnenten. Die Parameter, die Multicast übernimmt, sind ein Betreff oder eine Factory-Methode, die ein ConnectableObservable mit der connect () -Methode zurückgibt. Zum Abonnieren muss die Methode connect () aufgerufen werden.

Dieser Operator gibt ConnectableObservable zurück und muss die Methode connect () verwenden, um die Observablen zu abonnieren.

PublishBehaviour verwendet BehaviourSubject und gibt ConnectableObservable zurück. Die connect () -Methode muss verwendet werden, um das erstellte Observable zu abonnieren.

PublishBehaviour verwendet AsyncSubject und gibt ConnectableObservable zurück. Die connect () -Methode muss verwendet werden, um das erstellte Observable zu abonnieren.

PublishReplay verwendet ein Verhaltensthema, bei dem die Werte gepuffert und den neuen Abonnenten wiedergegeben werden können und ConnectableObservable zurückgegeben wird. Die connect () -Methode muss verwendet werden, um das erstellte Observable zu abonnieren.

Es ist ein Alias ​​für den Operator mutlicast (), mit dem einzigen Unterschied, dass Sie die Methode connect () nicht manuell aufrufen müssen, um das Abonnement zu starten.

Dieser Operator sorgt dafür, dass Fehler in der Quelle Observable abgefangen werden, indem eine neue Observable oder ein Fehler zurückgegeben wird.

Dieser Operator kümmert sich um einen erneuten Versuch an der Quelle. Beobachtbar, wenn ein Fehler vorliegt, und der erneute Versuch wird basierend auf der angegebenen Eingangsanzahl durchgeführt.