Freigeben über


IConnectableObservable<T> Interface

Stellt eine feststellbare, die verbunden und getrennt werden kann.

Namespace:System.Reactive.Subjects
Assembly: System.Reactive (in System.Reactive.dll)

Syntax

'Declaration
Public Interface IConnectableObservable(Of Out T) _
    Inherits IObservable(Of T)
'Usage
Dim instance As IConnectableObservable(Of Out T)
public interface IConnectableObservable<out T> : IObservable<T>
generic<typename T>
public interface class IConnectableObservable : IObservable<T>
type IConnectableObservable<'T> =  
    interface
        interface IObservable<'T>
    end
JScript does not support generic types and methods.

Typparameter

  • outT
    Der Typ.

    Dieser Typparameter ist kovariant. Das heißt, Sie können entweder den angegebenen Typ oder einen beliebigen Typ verwenden, der abgeleitet ist. Weitere Informationen zur Kovarianz und Kontravarianz finden Sie unter .

Der Typ "IConnectableObservable"<T> macht die folgenden Member verfügbar.

Methodik

  Name Beschreibung
öffentliche Methode Connect Verbindet die feststellbare.
öffentliche Methode Abonnieren (Geerbt von IObservable<T>.)

Nach oben

Erweiterungsmethoden

  Name Beschreibung
Public Extension Method Aggregat<T>(Func<T, T, T>) Überladen. Wendet eine Akkumulatorfunktion auf eine feststellbare Sequenz an. (Definiert durch Observable.)
Public Extension Method Aggregate<T, TAccumulate>(TAccumulate, Func<TAccumulate, T, TAccumulate>) Überladen. Wendet eine Akkumulatorfunktion auf eine feststellbare Sequenz mit dem angegebenen Ausgangswert an. (Definiert durch Observable.)
Public Extension Method Alle<T-> Bestimmt, ob alle Elemente einer feststellbaren Sequenz eine Bedingung erfüllen. (Definiert durch Observable.)
Public Extension Method Amb<T> Verteilt die observable Sequenz, die zuerst mit der angegebenen ersten und zweiten Sequenz reagiert. (Definiert durch Observable.)
Public Extension Method Und<T, TRight> Übereinstimmungen, wenn beide feststellbaren Sequenzen einen verfügbaren Wert aufweisen. (Definiert durch Observable.)
Public Extension Method <T->() Überladen. Bestimmt, ob eine feststellbare Sequenz Elemente enthält. (Definiert durch Observable.)
Public Extension Method Any<T>(Func<T, boolean>) Überladen. Bestimmt, ob alle Elemente einer feststellbaren Sequenz eine Bedingung erfüllen. (Definiert durch Observable.)
Public Extension Method AsObservable<T> Blendet die Identität einer feststellbaren Sequenz aus. (Definiert durch Observable.)
Public Extension Method AsQbservable<T> Wandelt eine observable Sequenz in eine abfragbare Observable-Sequenz um. (Definiert durch Qbservable.)
Public Extension Method AssertEqual<T-> (Definiert durch Erweiterungen.)
Public Extension Method Puffer-<T->(Int32) Überladen. Gibt jedes Element einer observierbaren Sequenz in aufeinander folgende nicht überlappende Puffer an, die basierend auf Elementanzahlsinformationen erzeugt werden. (Definiert durch Observable.)
Public Extension Method Puffer-<T->(TimeSpan) Überladen. Gibt jedes Element einer feststellbaren Sequenz in aufeinander folgende nicht überlappende Puffer an, die basierend auf Zeitangaben erzeugt werden. (Definiert durch Observable.)
Public Extension Method Puffer-<T->(Int32, Int32) Überladen. Gibt jedes Element einer observierbaren Sequenz in null oder mehr Puffer an, die basierend auf Elementanzahlsinformationen erzeugt werden. (Definiert durch Observable.)
Public Extension Method Puffer<T>(TimeSpan, IScheduler) Überladen. Gibt jedes Element einer feststellbaren Sequenz in aufeinander folgende nicht überlappende Puffer an, die basierend auf Zeitangaben erzeugt werden. (Definiert durch Observable.)
Public Extension Method Puffer<T>(TimeSpan, TimeSpan) Überladen. Gibt jedes Element einer observierbaren Sequenz in null oder mehr Puffer an, die basierend auf Zeitangaben erzeugt werden. (Definiert durch Observable.)
Public Extension Method Puffer<T>(TimeSpan, Int32) Überladen. Gibt jedes Element einer feststellbaren Sequenz in einen Puffer an, der gesendet wird, wenn es voll ist oder eine bestimmte Zeitspanne verstrichen ist. (Definiert durch Observable.)
Public Extension Method Puffer<T>(TimeSpan, TimeSpan, IScheduler) Überladen. Gibt jedes Element einer observierbaren Sequenz in null oder mehr Puffer an, die basierend auf Zeitangaben erzeugt werden. (Definiert durch Observable.)
Public Extension Method Puffer<T>(TimeSpan, Int32, IScheduler) Überladen. Gibt jedes Element einer feststellbaren Sequenz in einen Puffer an, der gesendet wird, wenn es voll ist oder eine bestimmte Zeitspanne verstrichen ist. (Definiert durch Observable.)
Public Extension Method Buffer<T, TBufferClosing>(Func<IObservable<TBufferClosing>>) Überladen. Gibt jedes Element einer observablen Sequenz in aufeinander folgende nicht überlappende Puffer an. (Definiert durch Observable.)
Public Extension Method Buffer<T, TBufferOpening, TBufferClosing>(IObservable<TBufferOpening>, Func<TBufferOpening, IObservable<TBufferClosing>>) Überladen. Gibt jedes Element einer abfragbaren Observable-Sequenz in aufeinander folgende nicht überlappende Puffer an. (Definiert durch Observable.)
Public Extension Method catch<T>(IObservable<T>) Überladen. Setzt eine observable Sequenz fort, die von einer Ausnahme mit der nächsten observablen Sequenz beendet wird. (Definiert durch Observable.)
Public Extension Method Catch<T, TException>(Func<TException, IObservable<T>>) Überladen. Setzt eine feststellbare Sequenz fort, die von einer Ausnahme des angegebenen Typs mit der observablen Sequenz beendet wird, die vom Handler erzeugt wird. (Definiert durch Observable.)
Public Extension Method CombineLatest<T, TSecond, TResult> Führt zwei feststellbare Sequenzen mit einer feststellbaren Sequenz zusammen, indem die Selektorfunktion verwendet wird, wenn eine der observablen Sequenzen ein Element erzeugt. (Definiert durch Observable.)
Public Extension Method Verketten<T-> Verkettet zwei observierbare Sequenzen. (Definiert durch Observable.)
Public Extension Method enthält<T->(T) Überladen. Bestimmt, ob eine Observable-Sequenz ein angegebenes Element mithilfe des Standardmäßigen Gleichheitsabgleichs enthält. (Definiert durch Observable.)
Public Extension Method enthält<T>(T, IEqualityComparer<T>) Überladen. Bestimmt, ob eine observable Sequenz ein angegebenes Element mit einer angegebenen System.Collections.Generic.IEqualityComparer< T>. (Definiert durch Observable.)
Public Extension Method Anzahl<T> Gibt einen Int32- zurück, der die Gesamtanzahl der Elemente in einer observierbaren Sequenz darstellt. (Definiert durch Observable.)
Public Extension Method DefaultIfEmpty<T>() Überladen. Gibt die Elemente der angegebenen Sequenz oder des Standardwerts des Typparameters in einer Singletonsequenz zurück, wenn die Sequenz leer ist. (Definiert durch Observable.)
Public Extension Method DefaultIfEmpty<T->(T) Überladen. Gibt die Elemente der angegebenen Sequenz oder des Standardwerts des Typparameters in einer Singletonsequenz zurück, wenn die Sequenz leer ist. (Definiert durch Observable.)
Public Extension Method Verzögerung<T>(TimeSpan) Überladen. Gibt die observable Sequenz nach Fälligkeitszeit mit der angegebenen Quelle und dueTime an. (Definiert durch Observable.)
Public Extension Method Delay<T>(DateTimeOffset) Überladen. Gibt die observable Sequenz nach Fälligkeitszeit mit der angegebenen Quelle und dueTime an. (Definiert durch Observable.)
Public Extension Method Verzögerung<T>(TimeSpan, IScheduler) Überladen. Gibt die observable Sequenz nach Fälligkeitszeit mit der angegebenen Quelle, dueTime und Scheduler an. (Definiert durch Observable.)
Public Extension Method Delay<T>(DateTimeOffset, IScheduler) Überladen. Gibt die observable Sequenz nach Fälligkeitszeit mit der angegebenen Quelle, dueTime und Scheduler an. (Definiert durch Observable.)
Public Extension Method Distinct<T>() Überladen. Gibt eine observable Sequenz zurück, die nur unterschiedliche Elemente mit einer angegebenen Quelle enthält. (Definiert durch Observable.)
Public Extension Method Distinct<T>(IEqualityComparer<T>) Überladen. Gibt eine Observable-Sequenz zurück, die nur unterschiedliche Elemente gemäß dem Vergleich enthält. (Definiert durch Observable.)
Public Extension Method Distinct<T, TKey>(Func<T, TKey>) Überladen. Gibt eine observable Sequenz zurück, die nur unterschiedliche Elemente gemäß keySelector enthält. (Definiert durch Observable.)
Public Extension Method Distinct<T, TKey>(Func<T, TKey>, IEqualityComparer<TKey>) Überladen. Gibt eine observable Sequenz zurück, die nur unterschiedliche Elemente gemäß keySelector enthält. (Definiert durch Observable.)
Public Extension Method DistinctUntilChanged<T>() Überladen. Gibt eine feststellbare Sequenz zurück, die nur unterschiedliche zusammenhängende Elemente mit einer angegebenen Quelle enthält. (Definiert durch Observable.)
Public Extension Method DistinctUntilChanged<T>(IEqualityComparer<T>) Überladen. Gibt eine feststellbare Sequenz zurück, die nur unterschiedliche zusammenhängende Elemente gemäß dem Vergleich enthält. (Definiert durch Observable.)
Public Extension Method DistinctUntilChanged<T, TKey>(Func<T, TKey>) Überladen. Gibt eine feststellbare Sequenz zurück, die nur unterschiedliche zusammenhängende Elemente gemäß keySelector enthält. (Definiert durch Observable.)
Public Extension Method DistinctUntilChanged<T, TKey>(Func<T, TKey>, IEqualityComparer<TKey>) Überladen. Gibt eine feststellbare Sequenz zurück, die nur unterschiedliche zusammenhängende Elemente gemäß keySelector und dem Comparer enthält. (Definiert durch Observable.)
Public Extension Method <T>(Aktion<T>) Überladen. Ruft eine Aktion für jedes Element in der observablen Sequenz auf. (Definiert durch Observable.)
Public Extension Method <T>(IObserver<T>) Überladen. Ruft eine Aktion für jedes Element in der observablen Sequenz auf und ruft eine Aktion nach einer außergewöhnlichen Beendigung der observablen Sequenz auf. (Definiert durch Observable.)
Public Extension Method T<T>(Aktion<T>, Aktion) Überladen. Ruft eine Aktion für jedes Element in der observablen Sequenz auf und ruft eine Aktion nach einer ordnungsgemäßen Beendigung der observablen Sequenz auf. (Definiert durch Observable.)
Public Extension Method T<T>(Aktion<T>, Aktion<Ausnahme>) Überladen. Ruft eine Aktion für jedes Element in der observablen Sequenz auf und ruft eine Aktion nach einer außergewöhnlichen Beendigung der observablen Sequenz auf. (Definiert durch Observable.)
Public Extension Method T<T>(Aktion<T>, Aktion<Ausnahme>, Aktion) Überladen. Ruft eine Aktion für jedes Element in der observablen Sequenz auf und ruft eine Aktion nach einer ordnungsgemäßen oder außergewöhnlichen Beendigung der observablen Sequenz auf. (Definiert durch Observable.)
Public Extension Method ElementAt<T> Gibt das Element an einem angegebenen Index in einer Sequenz zurück. (Definiert durch Observable.)
Public Extension Method ElementAtOrDefault<T-> Gibt das Element an einem angegebenen Index in einer Sequenz oder einem Standardwert zurück, wenn der Index außerhalb des Bereichs liegt. (Definiert durch Observable.)
Public Extension Method Schließlich<T> Ruft eine angegebene Aktion auf, nachdem die Observable-Quellsequenz normal oder durch eine Ausnahme beendet wurde. (Definiert durch Observable.)
Public Extension Method First<T>() Überladen. Gibt das erste Element einer feststellbaren Sequenz mit einer angegebenen Quelle zurück. (Definiert durch Observable.)
Public Extension Method First<T>(Func<T, Boolean>) Überladen. Gibt das erste Element einer observierbaren Sequenz zurück, die dem Prädikat entspricht. (Definiert durch Observable.)
Public Extension Method FirstOrDefault<T>() Überladen. Gibt das erste Element einer observablen Sequenz oder einen Standardwert zurück, wenn kein Wert gefunden wird. (Definiert durch Observable.)
Public Extension Method FirstOrDefault<T>(Func<T, boolean>) Überladen. Gibt das erste Element einer observablen Sequenz zurück, das dem Prädikat entspricht, oder einen Standardwert, wenn kein Wert gefunden wird. (Definiert durch Observable.)
Public Extension Method Foo<T, R> (Definiert durch MyExt.)
Public Extension Method ForEach<T> Ruft eine Aktion für jedes Element in der observablen Sequenz auf und blockiert, bis die Sequenz beendet wird. (Definiert durch Observable.)
Public Extension Method GetEnumerator<T-> Gibt einen Enumerator zurück, der alle Werte der observablen Sequenz aufzählt. (Definiert durch Observable.)
Public Extension Method GroupBy<T, TKey>(Func<T, TKey>) Überladen. Gruppiert die Elemente einer observierbaren Sequenz gemäß einer angegebenen Schlüsselmarkierfunktion. (Definiert durch Observable.)
Public Extension Method GroupBy<T, TKey>(Func<T, TKey>, IEqualityComparer<TKey>) Überladen. Gruppiert die Elemente einer feststellbaren Sequenz gemäß einer angegebenen Schlüsselmarkierfunktion und einem Vergleich. (Definiert durch Observable.)
Public Extension Method GroupBy<T, TKey, TElement>(Func<T, TKey>, Func<T, TElement>) Überladen. Gruppiert die Elemente einer feststellbaren Sequenz und wählt die resultierenden Elemente mithilfe einer angegebenen Funktion aus. (Definiert durch Observable.)
Public Extension Method GroupBy<T, TKey, TElement>(Func<T, TKey>, Func<T, TElement>, IEqualityComparer<TKey>) Überladen. Gruppiert die Elemente einer feststellbaren Sequenz gemäß einer angegebenen Schlüsselmarkierfunktion und dem Vergleich und wählt die resultierenden Elemente mithilfe einer angegebenen Funktion aus. (Definiert durch Observable.)
Public Extension Method GroupByUntil<T, TKey, TDuration>(Func<T, TKey>, Func<IGroupedObservable<TKey, T>, IObservable<TDuration>>) Überladen. Gruppiert die Elemente einer observierbaren Sequenz gemäß einer angegebenen Schlüsselmarkierfunktion. (Definiert durch Observable.)
Public Extension Method GroupByUntil<T, TKey, TDuration>(Func<T, TKey>, Func<IGroupedObservable<TKey, T>, IObservable<TDuration>>, IEqualityComparer<TKey>) Überladen. Gruppiert die Elemente einer feststellbaren Sequenz gemäß einer angegebenen Schlüsselmarkierfunktion und einem Vergleich. (Definiert durch Observable.)
Public Extension Method GroupByUntil<T, TKey, TElement, TDuration>(Func<T, TKey>, Func<T, TElement>, Func<IGroupedObservable<TKey, TElement>, IObservable<TDuration>>) Überladen. Gruppiert die Elemente einer feststellbaren Sequenz entsprechend einer angegebenen Schlüsselmarkierfunktion und wählt die resultierenden Elemente mithilfe einer angegebenen Funktion aus. (Definiert durch Observable.)
Public Extension Method GroupByUntil<T, TKey, TElement, TDuration>(Func<T, TKey>, Func<T, TElement>, Func<IGroupedObservable<TKey, TElement>, IObservable<TDuration>>, IEqualityComparer<TKey>) Überladen. Gruppiert die Elemente einer feststellbaren Sequenz gemäß einer angegebenen Schlüsselmarkierfunktion und dem Vergleich und wählt die resultierenden Elemente mithilfe einer angegebenen Funktion aus. (Definiert durch Observable.)
Public Extension Method GroupJoin<T, TRight, TLeftDuration, TRightDuration, TResult> Korreliert die Elemente zweier Sequenzen basierend auf überlappenden Daueren und gruppiert die Ergebnisse. (Definiert durch Observable.)
Public Extension Method IgnoreElements<T-> Ignoriert alle Werte in einer observierbaren Sequenz, wobei nur die Beendigungsmeldungen verbleiben. (Definiert durch Observable.)
Public Extension Method Join<T, TRight, TLeftDuration, TRightDuration, TResult> Korreliert die Elemente zweier Sequenzen basierend auf überlappenden Daueren. (Definiert durch Observable.)
Public Extension Method Letzten<T>() Überladen. Gibt das letzte Element einer feststellbaren Sequenz mit einer angegebenen Quelle zurück. (Definiert durch Observable.)
Public Extension Method Last<T>(Func<T, Boolean>) Überladen. Gibt das letzte Element einer observierbaren Sequenz zurück, die dem Prädikat entspricht. (Definiert durch Observable.)
Public Extension Method LastOrDefault<T>() Überladen. Gibt das letzte Element in der observablen Sequenz oder einen Standardwert zurück, wenn kein Wert gefunden wird. (Definiert durch Observable.)
Public Extension Method LastOrDefault<T>(Func<T, boolean>) Überladen. Gibt das letzte Element einer feststellbaren Sequenz zurück, das dem Prädikat entspricht, oder einen Standardwert, wenn kein Wert gefunden wird. (Definiert durch Observable.)
Public Extension Method Neuesten<T-> Gibt den neuesten Wert in einer observablen Sequenz an. (Definiert durch Observable.)
Public Extension Method LongCount<T> Gibt einen Int64- zurück, der die Gesamtanzahl der Elemente in einer observierbaren Sequenz darstellt. (Definiert durch Observable.)
Public Extension Method Materialisieren<T-> Materialisiert die impliziten Benachrichtigungen einer feststellbaren Sequenz als explizite Benachrichtigungswerte. (Definiert durch Observable.)
Public Extension Method Max<T>() Überladen. Gibt das maximale Element in einer observablen Sequenz zurück. (Definiert durch Observable.)
Public Extension Method Max<T>(IComparer<T>) Überladen. Gibt den Maximalwert in einer observablen Sequenz gemäß dem angegebenen Vergleich zurück. (Definiert durch Observable.)
Public Extension Method MaxBy<T, TKey>(Func<T, TKey>) Überladen. Gibt die Elemente in einer feststellbaren Sequenz mit dem maximalen Schlüsselwert zurück. (Definiert durch Observable.)
Public Extension Method MaxBy<T, TKey>(Func<T, TKey>, IComparer<TKey>) Überladen. Gibt die Elemente in einer feststellbaren Sequenz mit dem maximalen Schlüsselwert zurück. (Definiert durch Observable.)
Public Extension Method Zusammenführen<T>(IObservable<T>) Überladen. Führt eine feststellbare Sequenz von observierbaren Sequenzen in eine observierbare Sequenz zusammen. (Definiert durch Observable.)
Public Extension Method Zusammenführen<T>(IObservable<T>, IScheduler) Überladen. Führt zwei feststellbare Sequenzen in einer einzelnen observierbaren Sequenz zusammen. (Definiert durch Observable.)
Public Extension Method Min<T->() Überladen. Gibt das Mindestelement in einer observierbaren Sequenz zurück. (Definiert durch Observable.)
Public Extension Method Min<T>(IComparer<T>) Überladen. Gibt den Minimalwert in einer feststellbaren Sequenz gemäß dem angegebenen Vergleich zurück. (Definiert durch Observable.)
Public Extension Method MinBy<T, TKey>(Func<T, TKey>) Überladen. Gibt die Elemente in einer feststellbaren Sequenz mit dem Minimalschlüsselwert zurück. (Definiert durch Observable.)
Public Extension Method MinBy<T, TKey>(Func<T, TKey>, IComparer<TKey>) Überladen. Gibt die Elemente in einer feststellbaren Sequenz mit dem minimalen Schlüsselwert gemäß dem angegebenen Vergleich zurück. (Definiert durch Observable.)
Public Extension Method MostRecent<T> Gibt den neuesten Wert in einer observablen Sequenz an. (Definiert durch Observable.)
Public Extension Method Multicast<T, TResult>(ISubject<T, TResult>) Überladen. Gibt eine verbindebare feststellbare Sequenz zurück, die bei verbindung dazu führt, dass die Quellsequenz Ergebnisse in den angegebenen Betreff überträgt. (Definiert durch Observable.)
Public Extension Method Multicast<T, TIntermediate, TResult>(Func<ISubject<T, TIntermediate>>, Func<IObservable<TIntermediate>, IObservable<TResult>>) Überladen. Gibt eine feststellbare Sequenz zurück, die die Elemente einer Sequenz enthält, die durch Multicasting der Quellsequenz innerhalb einer Selektorfunktion erzeugt wird. (Definiert durch Observable.)
Public Extension Method Next<T> Gibt den nächsten Wert (Blockierung ohne Pufferung) in einer observierbaren Sequenz an. (Definiert durch Observable.)
Public Extension Method ObserveOn<T>(SynchronizationContext) Überladen. Benachrichtigen Sie Beobachter asynchron über den angegebenen Synchronisierungskontext. (Definiert durch Observable.)
Public Extension Method ObserveOn<T>(Steuerelement) Überladen. (Definiert durch ControlObservable.)
Public Extension Method ObserveOn<T>(Dispatcher) Überladen. (Definiert durch DispatcherObservable.)
Public Extension Method ObserveOn<T>(DispatcherScheduler) Überladen. (Definiert durch DispatcherObservable.)
Public Extension Method ObserveOn<T>(IScheduler) Überladen. Benachrichtigen Sie Beobachter asynchron über den angegebenen Zeitplan. (Definiert durch Observable.)
Public Extension Method ObserveOnDispatcher<T> (Definiert durch DispatcherObservable.)
Public Extension Method OnErrorResumeNext<T-> Setzt eine feststellbare Sequenz fort, die normal oder von einer Ausnahme mit der nächsten observablen Sequenz beendet wird. (Definiert durch Observable.)
Public Extension Method veröffentlichen<T>() Überladen. Gibt eine verbindungsfähige Observable-Sequenz zurück, die ein einzelnes Abonnement für die zugrunde liegende Sequenz gemeinsam verwendet. (Definiert durch Observable.)
Public Extension Method <T>(T) veröffentlichen Überladen. Gibt eine verbindungsfähige Observable-Sequenz zurück, die ein einzelnes Abonnement für die zugrunde liegende Sequenz gemeinsam verwendet und mit initialValue beginnt. (Definiert durch Observable.)
Public Extension Method Veröffentlichen<T, TResult>(Func<IObservable<T>, IObservable<TResult>>) Überladen. Gibt eine feststellbare Sequenz zurück, die das Ergebnis des Aufrufs des Selektors für eine verbindungsfähige Observable-Sequenz ist, die ein einzelnes Abonnement für die zugrunde liegende Sequenz freigibt. (Definiert durch Observable.)
Public Extension Method Veröffentlichen<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, T) Überladen. Gibt eine verbindungsfähige Observable-Sequenz zurück, die ein einzelnes Abonnement für die zugrunde liegende Sequenz gemeinsam verwendet und mit initialValue beginnt. (Definiert durch Observable.)
Public Extension Method PublishLast<T>() Überladen. Gibt eine feststellbare Sequenz zurück, die ein einzelnes Abonnement für die zugrunde liegende Sequenz verwendet, die nur die letzte Benachrichtigung enthält. (Definiert durch Observable.)
Public Extension Method PublishLast<T, TResult>(Func<IObservable<T>, IObservable<TResult>>) Überladen. Gibt eine feststellbare Sequenz zurück, die das Ergebnis des Aufrufs des Selektors für eine feststellbare Sequenz ist, die ein einzelnes Abonnement für die zugrunde liegende Sequenz freigibt, die nur die letzte Benachrichtigung enthält. (Definiert durch Observable.)
Public Extension Method RefCount<TSource-> Gibt eine observable Sequenz zurück, die mit der Quelle verbunden bleibt, solange mindestens ein Abonnement für die observable Sequenz vorhanden ist. (Definiert durch Observable.)
Public Extension Method <T->() wiederholen Überladen. Wiederholt die observable Sequenz auf unbestimmte Zeit. (Definiert durch Observable.)
Public Extension Method <T->(Int32)- wiederholen Überladen. Wiederholt die observable Sequenz auf unbestimmte Zeit. (Definiert durch Observable.)
Public Extension Method Wiedergabe<T>() Überladen. Gibt eine feststellbare Sequenz zurück, die ein einzelnes Abonnement für die zugrunde liegende Sequenz verwendet, die alle Benachrichtigungen wiedergibt. (Definiert durch Observable.)
Public Extension Method <T>(TimeSpan) Überladen. Gibt eine verbindungsfähige feststellbare Sequenz zurück, die ein einzelnes Abonnement für die zugrunde liegende Sequenz verwendet, in der alle Benachrichtigungen im Fenster wiedergegeben werden. (Definiert durch Observable.)
Public Extension Method Wiedergabe<T>(Int32) Überladen. Gibt eine verbindungsfähige feststellbare Sequenz zurück, die ein einzelnes Abonnement für die zugrunde liegende Sequenz zurückgibt, in der pufferSize-Benachrichtigungen wiedergegeben werden. (Definiert durch Observable.)
Public Extension Method Wiedergabe<T>(IScheduler) Überladen. Gibt eine feststellbare Sequenz zurück, die ein einzelnes Abonnement für die zugrunde liegende Sequenz verwendet, die alle Benachrichtigungen wiedergibt. (Definiert durch Observable.)
Public Extension Method Wiedergabe<T>(TimeSpan, IScheduler) Überladen. Gibt eine verbindungsfähige feststellbare Sequenz zurück, die ein einzelnes Abonnement für die zugrunde liegende Sequenz verwendet, in der alle Benachrichtigungen im Fenster wiedergegeben werden. (Definiert durch Observable.)
Public Extension Method Wiedergabe<T>(Int32, IScheduler) Überladen. Gibt eine verbindungsfähige feststellbare Sequenz zurück, die ein einzelnes Abonnement für die zugrunde liegende Sequenz zurückgibt, in der pufferSize-Benachrichtigungen wiedergegeben werden. (Definiert durch Observable.)
Public Extension Method Wiedergabe<T>(Int32, TimeSpan) Überladen. Gibt eine verbindungsfähige Observable-Sequenz zurück, die ein einzelnes Abonnement für die zugrunde liegende Sequenz zurückgibt, in der Benachrichtigungen im Fenster puffern. (Definiert durch Observable.)
Public Extension Method Wiedergabe<T>(Int32, TimeSpan, IScheduler) Überladen. Gibt eine verbindungsfähige Observable-Sequenz zurück, die ein einzelnes Abonnement für die zugrunde liegende Sequenz zurückgibt, in der Benachrichtigungen im Fenster puffern. (Definiert durch Observable.)
Public Extension Method Wiedergabe<T, TResult>(Func<IObservable<T>, IObservable<TResult>>) Überladen. Gibt eine feststellbare Sequenz zurück, die das Ergebnis des Aufrufs des Selektors für eine feststellbare Sequenz ist, die ein einzelnes Abonnement für die zugrunde liegende Sequenz gemeinsam verwendet und mit dem Anfangswert beginnt. (Definiert durch Observable.)
Public Extension Method Wiedergabe<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, IScheduler) Überladen. Gibt eine feststellbare Sequenz zurück, die das Ergebnis des Aufrufs des Selektors für eine feststellbare Sequenz ist, die ein einzelnes Abonnement für die zugrunde liegende Sequenz freigibt, in der alle Benachrichtigungen wiedergegeben werden. (Definiert durch Observable.)
Public Extension Method Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, TimeSpan) Überladen. Gibt eine feststellbare Sequenz zurück, die das Ergebnis des Aufrufs des Selektors für eine verbindungsfähige Observable-Sequenz ist, die ein einzelnes Abonnement für die zugrunde liegende Sequenz freigibt, die alle Benachrichtigungen im Fenster wiedergibt. (Definiert durch Observable.)
Public Extension Method Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, Int32) Überladen. Gibt eine feststellbare Sequenz zurück, die das Ergebnis des Aufrufs des Selektors für eine verbindungsfähige Observable-Sequenz ist, die ein einzelnes Abonnement für die zugrunde liegende sequenzbasierte Wiedergabe von BufferSize-Benachrichtigungen freigibt. (Definiert durch Observable.)
Public Extension Method Wiedergabe<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, TimeSpan, IScheduler) Überladen. Gibt eine feststellbare Sequenz zurück, die das Ergebnis des Aufrufs des Selektors für eine verbindungsfähige Observable-Sequenz ist, die ein einzelnes Abonnement für die zugrunde liegende Sequenz freigibt, die alle Benachrichtigungen im Fenster wiedergibt. (Definiert durch Observable.)
Public Extension Method Wiedergabe<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, Int32, IScheduler) Überladen. Gibt eine feststellbare Sequenz zurück, die das Ergebnis des Aufrufs des Selektors für eine verbindungsfähige Observable-Sequenz ist, die ein einzelnes Abonnement für die zugrunde liegende sequenzbasierte Wiedergabe von BufferSize-Benachrichtigungen freigibt. (Definiert durch Observable.)
Public Extension Method Replay<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, Int32, TimeSpan) Überladen. Gibt eine feststellbare Sequenz zurück, die das Ergebnis des Aufrufs des Selektors für eine verbindungsfähige Observable-Sequenz ist, die ein einzelnes Abonnement für die zugrunde liegende Sequenz zum Wiedergeben von PufferNize-Benachrichtigungen innerhalb des Fensters freigibt. (Definiert durch Observable.)
Public Extension Method Wiedergabe<T, TResult>(Func<IObservable<T>, IObservable<TResult>>, Int32, TimeSpan, IScheduler) Überladen. Gibt eine feststellbare Sequenz zurück, die das Ergebnis des Aufrufs des Selektors für eine verbindungsfähige Observable-Sequenz ist, die ein einzelnes Abonnement für die zugrunde liegende Sequenz zum Wiedergeben von PufferNize-Benachrichtigungen innerhalb des Fensters freigibt. (Definiert durch Observable.)
Public Extension Method Wiederholen<T->() Überladen. Wiederholt die observable Quellsequenz, bis sie erfolgreich beendet wird. (Definiert durch Observable.)
Public Extension Method <T->(Int32)- wiederholen Überladen. Wiederholt die observable Quellsequenz, bis sie erfolgreich beendet wird. (Definiert durch Observable.)
Public Extension Method Beispiel<T>(TimeSpan) Überladen. Gibt die Observable-Sequenz in jedem Intervall an. (Definiert durch Observable.)
Public Extension Method Beispiel<T>(TimeSpan, IScheduler) Überladen. Gibt die Observable-Sequenz in jedem Intervall mit der angegebenen Quelle, dem angegebenen Intervall und dem Zeitplan an. (Definiert durch Observable.)
Public Extension Method Beispiel<T, TSample>(IObservable<TSample>) Überladen. Gibt die feststellbare Sequenz bei Sampling-Ticks mit der angegebenen Quelle und dem Sampler ab. (Definiert durch Observable.)
Public Extension Method Scan<T>(Func<T, T, T>) Überladen. Wendet eine Akkumulatorfunktion über eine feststellbare Sequenz an und gibt jedes Zwischenergebnis mit der angegebenen Quelle und dem Akkumulator zurück. (Definiert durch Observable.)
Public Extension Method Scan<T, TAccumulate>(TAccumulate, Func<TAccumulate, T, TAccumulate>) Überladen. Wendet eine Akkumulatorfunktion auf eine feststellbare Sequenz an und gibt jedes Zwischenergebnis mit der angegebenen Quelle, dem Saatgut und dem Akkumulator zurück. (Definiert durch Observable.)
Public Extension Method Auswählen<T, TResult>(Func<T, TResult>) Überladen. Projiziert jedes Element einer observablen Sequenz in ein neues Formular mit der angegebenen Quelle und Auswahl. (Definiert durch Observable.)
Public Extension Method <T, TResult>auswählen (Func<T, Int32, TResult>) Überladen. Projiziert jedes Element einer feststellbaren Sequenz in ein neues Formular, indem er den Index des Elements mit der angegebenen Quelle und Auswahl einbezieht. (Definiert durch Observable.)
Public Extension Method SelectMany<T, TOther>(IObservable<TOther>) Überladen. Projiziert jedes Element einer observierbaren Sequenz auf eine feststellbare Sequenz und flacht die resultierenden observierbaren Sequenzen in eine feststellbare Sequenz. (Definiert durch Observable.)
Public Extension Method SelectMany<T, TResult>(Func<T, IObservable<TResult>>) Überladen. Projiziert jedes Element einer observierbaren Sequenz auf eine feststellbare Sequenz und flacht die resultierenden observierbaren Sequenzen in eine feststellbare Sequenz. (Definiert durch Observable.)
Public Extension Method SelectMany<T, TResult>(Func<T, IEnumerable<TResult>>) Überladen. Projiziert jedes Element einer observierbaren Sequenz auf eine feststellbare Sequenz und flacht die resultierenden observierbaren Sequenzen in eine feststellbare Sequenz. (Definiert durch Observable.)
Public Extension Method SelectMany<T, TResult>(Func<T, IObservable<TResult>>, Func<Exception, IObservable<TResult>>, Func<IObservable<TResult>>) Überladen. Projiziert jedes Element einer observierbaren Sequenz auf eine feststellbare Sequenz und flacht die resultierenden observierbaren Sequenzen in eine feststellbare Sequenz. (Definiert durch Observable.)
Public Extension Method SelectMany<T, TCollection, TResult>(Func<T, IEnumerable<TCollection>>, Func<T, TCollection, TResult>) Überladen. Projiziert jedes Element einer observierbaren Sequenz auf eine feststellbare Sequenz und flacht die resultierenden observierbaren Sequenzen in eine feststellbare Sequenz. (Definiert durch Observable.)
Public Extension Method SelectMany<T, TCollection, TResult>(Func<T, IObservable<TCollection>>, Func<T, TCollection, TResult>) Überladen. Projiziert jedes Element einer observierbaren Sequenz auf eine feststellbare Sequenz und flacht die resultierenden observierbaren Sequenzen in eine feststellbare Sequenz. (Definiert durch Observable.)
Public Extension Method SequenceEqual<T>(IObservable<T>) Überladen. Bestimmt, ob zwei Sequenzen gleich sind, indem die Elemente paarweise verglichen werden. (Definiert durch Observable.)
Public Extension Method SequenceEqual<T>(IObservable<T>, IEqualityComparer<T>) Überladen. Bestimmt, ob zwei Sequenzen gleich sind, indem die Elemente mit einem angegebenen Gleichheitsabgleich verglichen werden. (Definiert durch Observable.)
Public Extension Method single<T>() Überladen. Gibt das einzige Element einer observablen Sequenz zurück und löst eine Ausnahme aus, wenn nicht genau ein Element in der observablen Sequenz vorhanden ist. (Definiert durch Observable.)
Public Extension Method Single<T>(Func<T, boolean>) Überladen. Gibt das einzige Element einer observierbaren Sequenz zurück, das dem Prädikat entspricht, und löst eine Ausnahme aus, wenn es nicht genau ein Element in der observablen Sequenz gibt. (Definiert durch Observable.)
Public Extension Method SingleOrDefault<T>() Überladen. Gibt das einzige Element einer observablen Sequenz oder einen Standardwert zurück, wenn die observable Sequenz leer ist. (Definiert durch Observable.)
Public Extension Method SingleOrDefault<T>(Func<T, boolean>) Überladen. Gibt das einzige Element einer feststellbaren Sequenz zurück, das mit dem Prädikat übereinstimmt, oder einen Standardwert, wenn kein Wert gefunden wird. (Definiert durch Observable.)
Public Extension Method <T-> überspringen Umgeht eine angegebene Anzahl von Werten in einer observablen Sequenz und gibt dann die verbleibenden Werte zurück. (Definiert durch Observable.)
Public Extension Method SkipLast<T-> Umgeht eine angegebene Anzahl von Elementen am Ende einer observierbaren Sequenz. (Definiert durch Observable.)
Public Extension Method SkipUntil<T, TOther> Gibt die Werte aus der Quellbeobachtungssequenz nur zurück, nachdem die andere observable Sequenz einen Wert erzeugt. (Definiert durch Observable.)
Public Extension Method SkipWhile<T>(Func<T, boolean>) Überladen. Umgeht Werte in einer observierbaren Sequenz, solange eine angegebene Bedingung wahr ist, und gibt dann die verbleibenden Werte zurück. (Definiert durch Observable.)
Public Extension Method SkipWhile<T>(Func<T, Int32, Boolean>) Überladen. Umgeht Werte in einer observierbaren Sequenz, solange eine angegebene Bedingung wahr ist, und gibt dann die verbleibenden Werte zurück. (Definiert durch Observable.)
Public Extension Method StartWith<T>T[]) Überladen. Stellt eine Abfolge von Werten einer feststellbaren Sequenz mit der angegebenen Quelle und den angegebenen Werten voran. (Definiert durch Observable.)
Public Extension Method StartWith<T>(IScheduler, T[]) Überladen. Stellt eine Abfolge von Werten einer feststellbaren Sequenz mit der angegebenen Quelle, dem Angegebenen Zeitplan und den Werten voran. (Definiert durch Observable.)
Public Extension Method Abonnieren<T>() Überladen. Wertet die observable Sequenz mit einer angegebenen Quelle aus. (Definiert durch ObservableExtensions.)
Public Extension Method Abonnieren<T>(Aktion<T>) Überladen. Abonniert einen Elementhandler für eine observable Sequenz. (Definiert durch ObservableExtensions.)
Public Extension Method Abonnieren<T>(Aktion<T>, Aktion<Ausnahme>) Überladen. Abonniert einen Elementhandler und einen Ausnahmehandler für eine observable Sequenz. (Definiert durch ObservableExtensions.)
Public Extension Method Abonnieren<T>(Aktion<T>, Aktion) Überladen. Abonniert einen Elementhandler und einen Abschlusshandler für eine observable Sequenz. (Definiert durch ObservableExtensions.)
Public Extension Method Abonnieren<T>(Aktion<T>, Aktion<Ausnahme>, Aktion) Überladen. Abonniert einen Elementhandler, einen Ausnahmehandler und einen Abschlusshandler für eine observable Sequenz. (Definiert durch ObservableExtensions.)
Public Extension Method SubscribeOn<T>(SynchronizationContext) Überladen. Asynchron abonniert und gekündigt Beobachter für den angegebenen Synchronisierungskontext. (Definiert durch Observable.)
Public Extension Method SubscribeOn<T>(Steuerelement) Überladen. (Definiert durch ControlObservable.)
Public Extension Method SubscribeOn<T>(Dispatcher) Überladen. (Definiert durch DispatcherObservable.)
Public Extension Method SubscribeOn<T>(DispatcherScheduler) Überladen. (Definiert durch DispatcherObservable.)
Public Extension Method SubscribeOn<T>(IScheduler) Überladen. Asynchron abonniert und gekündigt Beobachter am angegebenen Zeitplan. (Definiert durch Observable.)
Public Extension Method SubscribeOnDispatcher<T> (Definiert durch DispatcherObservable.)
Public Extension Method Synchronisieren<T->() Überladen. Synchronisiert die observable Sequenz. (Definiert durch Observable.)
Public Extension Method synchronisieren<T>(Objekt) Überladen. Synchronisiert die observable Sequenz. (Definiert durch Observable.)
Public Extension Method <T-> Gibt eine angegebene Anzahl zusammenhängender Werte vom Anfang einer observablen Sequenz zurück. (Definiert durch Observable.)
Public Extension Method TakeLast<T-> Gibt eine angegebene Anzahl zusammenhängender Elemente vom Ende einer observierbaren Sequenz zurück. (Definiert durch Observable.)
Public Extension Method TakeUntil<T, TOther> Gibt die Werte aus der Observable-Quellsequenz zurück, bis die andere observable Sequenz einen Wert erzeugt. (Definiert durch Observable.)
Public Extension Method TakeWhile<T>(Func<T, boolean>) Überladen. Gibt Werte aus einer feststellbaren Sequenz zurück, solange eine angegebene Bedingung wahr ist, und überspringt dann die verbleibenden Werte. (Definiert durch Observable.)
Public Extension Method TakeWhile<T>(Func<T, Int32, Boolean>) Überladen. Gibt Werte aus einer feststellbaren Sequenz zurück, solange eine angegebene Bedingung wahr ist, und überspringt dann die verbleibenden Werte. (Definiert durch Observable.)
Public Extension Method Dann<T, TResult> Übereinstimmungen, wenn die Observable-Sequenz einen verfügbaren Wert aufweist und den Wert projektiert. (Definiert durch Observable.)
Public Extension Method Drosselung<T>(TimeSpan) Überladen. Ignoriert die Werte aus einer feststellbaren Sequenz, auf die ein anderer Wert vor Fälligkeitszeit mit der angegebenen Quelle und dueTime folgt. (Definiert durch Observable.)
Public Extension Method Drosselung<T>(TimeSpan, IScheduler) Überladen. Ignoriert die Werte aus einer feststellbaren Sequenz, auf die ein anderer Wert vor Fälligkeitszeit mit der angegebenen Quelle, dueTime und Scheduler folgt. (Definiert durch Observable.)
Public Extension Method TimeInterval<T>() Überladen. Zeichnet das Zeitintervall zwischen aufeinander folgenden Werten in einer observierbaren Sequenz mit der angegebenen Quelle auf. (Definiert durch Observable.)
Public Extension Method timeInterval<T>(IScheduler) Überladen. Zeichnet das Zeitintervall zwischen aufeinander folgenden Werten in einer observierbaren Sequenz mit der angegebenen Quelle und dem Zeitplan auf. (Definiert durch Observable.)
Public Extension Method Timeout<T>(TimeSpan) Überladen. Gibt entweder die observable Sequenz oder eine TimeoutException zurück, wenn DueTime verstrichen ist. (Definiert durch Observable.)
Public Extension Method Timeout<T>(DateTimeOffset) Überladen. Gibt entweder die observable Sequenz oder eine TimeoutException zurück, wenn DueTime verstrichen ist. (Definiert durch Observable.)
Public Extension Method Timeout<T>(TimeSpan, IObservable<T>) Überladen. Gibt die observable Quellsequenz oder die andere feststellbare Sequenz zurück, wenn DueTime verstrichen ist. (Definiert durch Observable.)
Public Extension Method Timeout<T>(DateTimeOffset, IObservable<T>) Überladen. Gibt entweder die observable Sequenz oder eine TimeoutException zurück, wenn DueTime verstrichen ist. (Definiert durch Observable.)
Public Extension Method Timeout<T>(TimeSpan, IScheduler) Überladen. Gibt entweder die observable Sequenz oder eine TimeoutException zurück, wenn DueTime verstrichen ist. (Definiert durch Observable.)
Public Extension Method Timeout-<T>(DateTimeOffset, IScheduler) Überladen. Gibt entweder die observable Sequenz oder eine TimeoutException zurück, wenn DueTime verstrichen ist. (Definiert durch Observable.)
Public Extension Method Timeout<T>(TimeSpan, IObservable<T>, IScheduler) Überladen. Gibt die observable Quellsequenz oder die andere feststellbare Sequenz zurück, wenn DueTime verstrichen ist. (Definiert durch Observable.)
Public Extension Method Timeout<T>(DateTimeOffset, IObservable<T>, IScheduler) Überladen. Gibt die observable Quellsequenz oder die andere feststellbare Sequenz zurück, wenn DueTime verstrichen ist. (Definiert durch Observable.)
Public Extension Method Timestamp<T>() Überladen. Zeichnet den Zeitstempel für jeden Wert in einer observablen Sequenz mit der angegebenen Quelle auf. (Definiert durch Observable.)
Public Extension Method <T>(IScheduler) Überladen. Zeichnet den Zeitstempel für jeden Wert in einer observierbaren Sequenz mit der angegebenen Quelle und dem angegebenen Zeitplan auf. (Definiert durch Observable.)
Public Extension Method ToArray-<T-> Erstellt ein Array aus einer observablen Sequenz. (Definiert durch Observable.)
Public Extension Method ToDictionary<T, TKey>(Func<T, TKey>) Überladen. Erstellt ein Wörterbuch aus einer observierbaren Sequenz gemäß einer angegebenen Schlüsselauswahlfunktion. (Definiert durch Observable.)
Public Extension Method ToDictionary<T, TKey>(Func<T, TKey>, IEqualityComparer<TKey>) Überladen. Erstellt ein Wörterbuch aus einer feststellbaren Sequenz gemäß einer angegebenen Schlüsselauswahlfunktion und einem Vergleichsmodul. (Definiert durch Observable.)
Public Extension Method ToDictionary<T, TKey, TElement>(Func<T, TKey>, Func<T, TElement>) Überladen. Erstellt ein Wörterbuch aus einer feststellbaren Sequenz gemäß einer angegebenen Schlüsselmarkierfunktion und einer Elementauswahlfunktion. (Definiert durch Observable.)
Public Extension Method ToDictionary<T, TKey, TElement>(Func<T, TKey>, Func<T, TElement>, IEqualityComparer<TKey>) Überladen. Erstellt ein Wörterbuch aus einer feststellbaren Sequenz gemäß einer angegebenen Schlüsselauswahlfunktion, einem Vergleichsmodul und einer Elementauswahlfunktion. (Definiert durch Observable.)
Public Extension Method toEnumerable<T> Wandelt eine feststellbare Sequenz in eine aufzählbare Sequenz um. (Definiert durch Observable.)
Public Extension Method ToEvent-<T-> Macht eine observable Sequenz als Objekt mit einem .NET-Ereignis mit einer angegebenen Quelle verfügbar. (Definiert durch Observable.)
Public Extension Method ToList-<T-> Erstellt eine Liste aus einer observablen Sequenz. (Definiert durch Observable.)
Public Extension Method ToLookup<T, TKey>(Func<T, TKey>) Überladen. Erstellt einen Nachschlagevorgang aus einer feststellbaren Sequenz gemäß einer angegebenen Tastenauswahlfunktion. (Definiert durch Observable.)
Public Extension Method ToLookup<T, TKey>(Func<T, TKey>, IEqualityComparer<TKey>) Überladen. Erstellt einen Nachschlagevorgang aus einer observierbaren Sequenz gemäß einer angegebenen Tastenauswahlfunktion und einem Vergleichsmodul. (Definiert durch Observable.)
Public Extension Method ToLookup<T, TKey, TElement>(Func<T, TKey>, Func<T, TElement>) Überladen. Erstellt einen Nachschlagevorgang aus einer feststellbaren Sequenz gemäß einer angegebenen Schlüsselmarkierfunktion und einer Elementauswahlfunktion. (Definiert durch Observable.)
Public Extension Method ToLookup<T, TKey, TElement>(Func<T, TKey>, Func<T, TElement>, IEqualityComparer<TKey>) Überladen. Erstellt einen Nachschlagevorgang aus einer feststellbaren Sequenz gemäß einer angegebenen Schlüsselmarkierfunktion, einem Vergleichsmodul und einer Elementauswahlfunktion. (Definiert durch Observable.)
Public Extension Method toTask<T>() Überladen. Gibt einen Vorgang zurück, der den letzten Wert der observablen Sequenz enthält. (Definiert durch TaskObservableExtensions.)
Public Extension Method toTask<T>(Object) Überladen. Gibt einen Vorgang zurück, der den letzten Wert der observablen Sequenz enthält. (Definiert durch TaskObservableExtensions.)
Public Extension Method toTask<T>(CancellationToken) Überladen. Gibt einen Vorgang zurück, der den letzten Wert der observablen Sequenz enthält. (Definiert durch TaskObservableExtensions.)
Public Extension Method toTask<T>(CancellationToken, Object) Überladen. Gibt einen Vorgang zurück, der den letzten Wert der observablen Sequenz enthält. (Definiert durch TaskObservableExtensions.)
Public Extension Method Wo<T>(Func<T, boolesche>) Überladen. Filtert die Elemente einer feststellbaren Sequenz basierend auf einem Prädikat. (Definiert durch Observable.)
Public Extension Method Where<T>(Func<T, Int32, Boolean>) Überladen. Filtert die Elemente einer feststellbaren Sequenz basierend auf einem Prädikat, indem der Index des Elements einbezogen wird. (Definiert durch Observable.)
Public Extension Method Window<T>(Int32) Überladen. Projiziert jedes Element einer observierbaren Sequenz in aufeinander folgende nicht überlappende Fenster, die basierend auf Elementanzahlsinformationen erzeugt werden. (Definiert durch Observable.)
Public Extension Method < >(TimeSpan) Überladen. Projiziert jedes Element einer observierbaren Sequenz in aufeinander folgende nicht überlappende Fenster, die basierend auf Zeitangaben erzeugt werden. (Definiert durch Observable.)
Public Extension Method Window<T>(Int32, Int32) Überladen. Projiziert jedes Element einer observierbaren Sequenz in null oder mehr Fenster, die basierend auf Elementanzahlsinformationen erzeugt werden. (Definiert durch Observable.)
Public Extension Method Window<T>(TimeSpan, IScheduler) Überladen. Projiziert jedes Element einer observierbaren Sequenz in aufeinander folgende nicht überlappende Fenster, die basierend auf Zeitangaben erzeugt werden. (Definiert durch Observable.)
Public Extension Method Window<T>(TimeSpan, TimeSpan) Überladen. Projiziert jedes Element einer feststellbaren Sequenz in null oder mehr Fenster, die basierend auf Zeitangaben erzeugt werden. (Definiert durch Observable.)
Public Extension Method <T>(TimeSpan, Int32) Überladen. Projiziert jedes Element einer observierbaren Sequenz in ein Fenster, das abgeschlossen wird, wenn es voll ist oder eine bestimmte Zeitspanne verstrichen ist. (Definiert durch Observable.)
Public Extension Method Window<T>(TimeSpan, TimeSpan, IScheduler) Überladen. Projiziert jedes Element einer feststellbaren Sequenz in null oder mehr Fenster, die basierend auf Zeitangaben erzeugt werden. (Definiert durch Observable.)
Public Extension Method Window<T>(TimeSpan, Int32, IScheduler) Überladen. Projiziert jedes Element einer observierbaren Sequenz in ein Fenster, das abgeschlossen wird, wenn es voll ist oder eine bestimmte Zeitspanne verstrichen ist. (Definiert durch Observable.)
Public Extension Method Window<T, TWindowClosing>(Func<IObservable<TWindowClosing>>) Überladen. Projiziert jedes Element einer observierbaren Sequenz in aufeinander folgende nicht überlappende Fenster. (Definiert durch Observable.)
Public Extension Method Window<T, TWindowOpening, TWindowClosing>(IObservable<TWindowOpening>, Func<TWindowOpening, IObservable<TWindowClosing>>) Überladen. Projiziert jedes Element einer feststellbaren Sequenz in null oder mehr Fenster. (Definiert durch Observable.)
Public Extension Method Zip<T, TSecond, TResult>(IObservable<TSecond>, Func<T, TSecond, TResult>) Überladen. Führt zwei feststellbare Sequenzen in einer feststellbaren Sequenz zusammen, indem sie ihre Elemente in paarweiser Weise kombinieren. (Definiert durch Observable.)
Public Extension Method Zip<T, TSecond, TResult>(IEnumerable<TSecond>, Func<T, TSecond, TResult>) Überladen. Führt eine observable Sequenz und eine aufzählbare Sequenz mit einer observierbaren Sequenz mithilfe der Selektorfunktion zusammen. (Definiert durch Observable.)

Nach oben

Bemerkungen

Kalte Observables beginnen mit dem Abonnement, d. h., die observable Sequenz beginnt nur, Werte an die Beobachter zu pushen, wenn Subscribe aufgerufen wird. Werte werden auch nicht für Abonnenten freigegeben. Dies unterscheidet sich von heißen Observables wie Mausverschiebungsereignissen oder Aktienticker, die bereits Werte erzeugen, noch bevor ein Abonnement aktiv ist. Wenn ein Beobachter eine heiße observable Sequenz abonniert, erhält er den aktuellen Wert im Datenstrom. Die heiße Observable-Sequenz wird für alle Abonnenten freigegeben, und jeder Abonnent wird den nächsten Wert in der Sequenz pusht. Selbst wenn niemand einen bestimmten Aktienticker abonniert hat, wird der Ticker seinen Wert basierend auf der Marktbewegung weiter aktualisieren. Wenn ein Abonnent Interesse an diesem Ticker registriert, erhält er automatisch den neuesten Tick.

Beispiele

Im folgenden Beispiel konvertieren wir eine kalte observable Sequenzquelle mithilfe des Publish-Operators in eine heiße Quelle, die einen IConnectableObservable-<T-> Instanz zurückgibt, die wir heißen. Der Veröffentlichungsoperator bietet einen Mechanismus zum Freigeben von Abonnements, indem ein einzelnes Abonnement an mehrere Abonnenten übertragen wird. Hot fungiert als Proxy und abonniert die Quelle und empfängt dann Werte aus der Quelle, pusht sie an seine eigenen Abonnenten. Um ein Abonnement für die Sicherungsquelle einzurichten und mit dem Empfangen von Werten zu beginnen, verwenden wir die IConnectableObservable.Connect()-Methode. Da IConnectableObservable IObservable erbt, können wir subscribe to subscribe to this hot sequence auch vor dem Start der Ausführung verwenden. Beachten Sie, dass im Beispiel die Hotsequenz beim Abonnieren von Subscription1 nicht gestartet wurde. Daher wird kein Wert an den Abonnenten übertragen. Nach dem Aufrufen von Connect werden die Werte dann an "subscription1" übertragen. Nach einer Verzögerung von 3 Sekunden abonniert Subscription2 hot und beginnt, die Werte sofort von der aktuellen Position (3 in diesem Fall) bis zum Ende zu erhalten. Die Ausgabe sieht wie folgt aus:

Current Time: 6/1/2011 3:38:49 PM

Current Time after 1st subscription: 6/1/2011 3:38:49 PM

Current Time after Connect: 6/1/2011 3:38:52 PM

Observer 1: OnNext: 0

Observer 1: OnNext: 1

Current Time just before 2nd subscription: 6/1/2011 3:38:55 PM 

Observer 1: OnNext: 2

Observer 1: OnNext: 3

Observer 2: OnNext: 3

Observer 1: OnNext: 4

Observer 2: OnNext: 4
       
Console.WriteLine("Current Time: " + DateTime.Now);
var source = Observable.Interval(TimeSpan.FromSeconds(1));   //creates a sequence

IConnectableObservable<long> hot = Observable.Publish<long>(source);  // convert the sequence into a hot sequence

IDisposable subscription1 = hot.Subscribe(     // no value is pushed to 1st subscription at this point
                            x => Console.WriteLine("Observer 1: OnNext: {0}", x),
                            ex => Console.WriteLine("Observer 1: OnError: {0}", ex.Message),
                            () => Console.WriteLine("Observer 1: OnCompleted"));
Console.WriteLine("Current Time after 1st subscription: " + DateTime.Now);
Thread.Sleep(3000);  //idle for 3 seconds
hot.Connect();       // hot is connected to source and starts pushing value to subscribers 
Console.WriteLine("Current Time after Connect: " + DateTime.Now);
Thread.Sleep(3000);  //idle for 3 seconds
Console.WriteLine("Current Time just before 2nd subscription: " + DateTime.Now);
IDisposable subscription2 = hot.Subscribe(     // value will immediately be pushed to 2nd subscription
                            x => Console.WriteLine("Observer 2: OnNext: {0}", x),
                            ex => Console.WriteLine("Observer 2: OnError: {0}", ex.Message),
                            () => Console.WriteLine("Observer 2: OnCompleted"));
Console.ReadKey();

Siehe auch

Referenz

System.Reactive.Subjects Namespace