DataflowBlock Osztály

Definíció

Névtér:

System.Threading.Tasks.Dataflow

Szerelvény:

System.Threading.Tasks.Dataflow.dll

Forrás:

DataflowBlock.cs

Statikus (megosztott Visual Basic) metódusokat biztosít az adatfolyamblokkok használatához.

public ref class DataflowBlock abstract sealed

public static class DataflowBlock

type DataflowBlock = class

Public Module DataflowBlock

Öröklődés

Object

DataflowBlock

Metódusok

Név	Description
AsObservable<TOutput>(ISourceBlock<TOutput>)	Új IObservable<T> absztrakciót hoz létre a ISourceBlock<TOutput>.
AsObserver<TInput>(ITargetBlock<TInput>)	Új IObserver<T> absztrakciót hoz létre a ITargetBlock<TInput>.
Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>, DataflowBlockOptions)	Három adatfolyamforrást figyel, és a megadott kezelőt invokálásával jelzi, hogy melyik forrás teszi először elérhetővé az adatokat.
Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>)	Három adatfolyamforrást figyel, és a megadott kezelőt invokálásával jelzi, hogy melyik forrás teszi először elérhetővé az adatokat.
Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, DataflowBlockOptions)	Két adatfolyamforrást figyel, és a megadott kezelőt invokálásával adja meg, hogy melyik forrás teszi először elérhetővé az adatokat.
Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>)	Két adatfolyamforrást figyel, és a megadott kezelőt invokálásával adja meg, hogy melyik forrás teszi először elérhetővé az adatokat.
Encapsulate<TInput,TOutput>(ITargetBlock<TInput>, ISourceBlock<TOutput>)	Egy cél és egy forrás beágyazása egyetlen propagátorba.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)	A megadott szűrővel csatolja a ISourceBlock<TOutput> megadotthoz ITargetBlock<TInput> .
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)	A megadott szűrővel csatolja a ISourceBlock<TOutput> megadotthoz ITargetBlock<TInput> .
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	A megadotthoz csatolja a ISourceBlock<TOutput> elemet ITargetBlock<TInput>.
NullTarget<TInput>()	Lekéri a célblokkot, amely szinkron módon fogadja el a neki felajánlott összes üzenetet, és elveti őket.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Task<TResult> A rendelkezésre álló kimenet forrását aszinkron módon figyeli.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	Task<TResult> A rendelkezésre álló kimenet forrását aszinkron módon figyeli.
Post<TInput>(ITargetBlock<TInput>, TInput)	Elem bejegyzése a következőre: .>
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Szinkron módon kap egy értéket egy megadott forrástól, és egy jogkivonatot biztosít a művelet megszakításához.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Szinkron módon kap egy értéket egy megadott forrástól, amely egy jogkivonatot biztosít a művelet megszakításához és egy opcionális időtúllépési időköz megfigyeléséhez.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Szinkron módon kap egy értéket egy megadott forrástól, figyelembe véve az opcionális időtúllépési időszakot.
Receive<TOutput>(ISourceBlock<TOutput>)	Szinkron módon kap egy értéket egy megadott forrásból.
ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)	Létrehoz egy olyan alkalmazást IAsyncEnumerable<T> , amely lehetővé teszi az összes adat fogadását a forrásból.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Aszinkron módon kap egy értéket egy megadott forrástól, és egy jogkivonatot biztosít a művelet megszakításához.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Aszinkron módon kap egy értéket egy megadott forrástól, amely jogkivonatot biztosít a művelet megszakításához és egy opcionális időtúllépési időköz megfigyeléséhez.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Aszinkron módon kap egy értéket egy megadott forrástól, egy opcionális időtúllépési időszakot figyelve.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	Aszinkron módon egy adott forrásból kap értéket.
SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken)	Aszinkron módon üzenetet küld a célüzenetblokknak, ami lehetővé teszi a halasztást.
SendAsync<TInput>(ITargetBlock<TInput>, TInput)	Aszinkron módon üzenetet küld a célüzenetblokknak, ami lehetővé teszi a halasztást.
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)	Megkísérli szinkronizálva fogadni az elemet a ISourceBlock<TOutput>.