ein einfaches Szenario Gegeben:Herzschlag-Muster unter Verwendung von reaktiver Erweiterung
A und B in einem Raum ist, ein Gespräch mit B. Der Raum ist dunkel und B konnte sehen, A. nicht wie B vorstellen konnte, wenn A Pausieren oder A wird aus dem Raum entführt?
Wenn A spricht, bietet A IObservable Talk, dass B abonniert anschließend an Talk.Subscribe (string => verarbeiten was A sagte). B könnte gleichzeitig Observable.Interval Heartbeat als Heartbeat-Überprüfung abonnieren.
Meine Frage ist, was Operator ich nutzen, um sollte zwei IObservable fusionieren/kombinieren, so dass, wenn kein Element aus Diskussion über zwei Elemente von ist Heartbeat, B die A entführt wurde übernehmen wird.
Bitte beachten Sie, dass ich eine Variable vermeiden möchte, um den Zustand zu speichern, da es die Nebenwirkung verursachen kann, wenn ich diese Variable nicht richtig synchronisiere.
Danke,
Dank @Shlomo für Ihre Antwort , gibt es irgendwelche Möglichkeiten, diese Lösung auf n + 1 wh zu skalieren Ist n die Anzahl der Sprecher, die nur zur Laufzeit ermittelt werden können? – LxL
Höchstwahrscheinlich. Könnten Sie das Problem besser definieren? – Shlomo
Derzeit gibt es nur A und B, ich würde gerne sehen, ob die gleiche Lösung für C, D, E, F gelten kann, wenn die Rolle von A wie wirkt. Die Lösung, an die ich bisher gedacht habe, ist eine Liste von IObservable und eine Liste von Subskriptionen, die zur Laufzeit hinzugefügt werden. Gibt es einen eleganteren Weg? – LxL