DataflowBlock Klasse
Definition
Wichtig
Einige Informationen beziehen sich auf Vorabversionen, die vor dem Release ggf. grundlegend überarbeitet werden. Microsoft übernimmt hinsichtlich der hier bereitgestellten Informationen keine Gewährleistungen, seien sie ausdrücklich oder konkludent.
Stellt einen Satz mit statischen Methoden (Shared in Visual Basic) für die Arbeit mit bestimmten Datenflussblöcken bereit.
public ref class DataflowBlock abstract sealedpublic static class DataflowBlocktype DataflowBlock = classPublic Module DataflowBlock- Vererbung
-
DataflowBlock
Hinweise
Hinweis
Die TPL-Datenflussbibliothek (System.Threading.Tasks.Dataflow-Namespace) wird nicht mit .NET ausgeliefert. Öffnen Sie zum Installieren des System.Threading.Tasks.Dataflow-Namespace in Visual Studio Ihr Projekt, wählen Sie im Menü Projekt die Option NuGet-Pakete verwalten aus, und suchen Sie online nach dem System.Threading.Tasks.Dataflow-Paket. Alternativ können Sie es mithilfe der .NET Core-CLI installieren und dazu dotnet add package System.Threading.Tasks.Dataflow ausführen.
Methoden
| AsObservable<TOutput>(ISourceBlock<TOutput>) |
Erstellt eine neue IObservable<T> Abstraktion über ISourceBlock<TOutput>. |
| AsObserver<TInput>(ITargetBlock<TInput>) |
Erstellt eine neue IObserver<T>-Abstraktion über ITargetBlock<TInput>. |
| Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>) |
Überwacht drei Datenflussquellen, wobei der angegebene Handler für eine beliebige Quelle aufgerufen wird, die Daten zuerst verfügbar macht. |
| Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>, DataflowBlockOptions) |
Überwacht drei Datenflussquellen, wobei der angegebene Handler für eine beliebige Quelle aufgerufen wird, die Daten zuerst verfügbar macht. |
| Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>) |
Überwacht zwei Datenflussquellen, wobei der angegebene Handler für eine beliebige Quelle aufgerufen wird, die Daten zuerst verfügbar macht. |
| Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, DataflowBlockOptions) |
Überwacht zwei Datenflussquellen, wobei der angegebene Handler für eine beliebige Quelle aufgerufen wird, die Daten zuerst verfügbar macht. |
| Encapsulate<TInput,TOutput>(ITargetBlock<TInput>, ISourceBlock<TOutput>) |
Kapselt ein Ziel und eine Quelle in eine einzelne Propagierung. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>) |
Verbindet ISourceBlock<TOutput> mit dem angegebenen ITargetBlock<TInput>-Objekt. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>) |
Verknüpft ISourceBlock<TOutput> mit der angegebenen ITargetBlock<TInput>-Objekt mithilfe des angegebenen Filters. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>) |
Verknüpft ISourceBlock<TOutput> mit der angegebenen ITargetBlock<TInput>-Objekt mithilfe des angegebenen Filters. |
| NullTarget<TInput>() |
Ruft ab einen Zielblock ab, der alle Meldungen synchron akzeptiert, die für ihn bereitgestellt werden, und diese dann ablegt. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>) |
Stellt eine Task<TResult> bereit, die asynchron die Quelle für verfügbare Ausgabe überwacht. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Stellt ein Task<TResult>-Objekt bereit, das asynchron die Quelle für eine verfügbare Ausgabe überwacht. |
| Post<TInput>(ITargetBlock<TInput>, TInput) |
Fügt dem ITargetBlock<TInput> ein Element hinzu. |
| Receive<TOutput>(ISourceBlock<TOutput>) |
Empfängt synchron einen Wert aus der angegebenen Quelle. |
| Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Erhält synchron einen Wert aus einer angegebenen Quelle und stellt ein Token bereit, um die Operation abzubrechen. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Empfängt synchron einen Wert aus einer angegebenen Quelle und beachtet ein optionales Timeout. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Empfängt synchron einen Wert aus einer angegebenen Quelle, stellt ein Token bereit, um den Vorgang abzubrechen und beachtet ein optionales Timeoutintervall. |
| ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken) |
Erstellt ein IAsyncEnumerable<T> Objekt, das den Empfang aller Daten aus der Quelle ermöglicht. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>) |
Empfängt asynchron einen Wert aus der angegebenen Quelle. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Erhält asynchron einen Wert aus einer angegebenen Quelle und stellt ein Token bereit, um die Operation abzubrechen. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Empfängt asynchron einen Wert aus einer angegebenen Quelle und beachtet ein optionales Timeout. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Empfängt asynchron einen Wert aus einer angegebenen Quelle, stellt ein Token bereit, um den Vorgang abzubrechen und beachtet ein optionales Timeoutintervall. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput) |
Gewährt dem Zielmeldungsblock asynchron eine Meldung an und ermöglicht einen Aufschub. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken) |
Gewährt dem Zielmeldungsblock asynchron eine Meldung an und ermöglicht einen Aufschub. |
| TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput) |
Versucht, ein Element von ISourceBlock<TOutput> synchron zu empfangen. |