DataflowBlock Klass
Definition
Viktigt
En del information gäller för förhandsversionen av en produkt och kan komma att ändras avsevärt innan produkten blir allmänt tillgänglig. Microsoft lämnar inga garantier, uttryckliga eller underförstådda, avseende informationen som visas här.
Innehåller en uppsättning statiska metoder (delas i Visual Basic) för att arbeta med dataflödesblock.
public ref class DataflowBlock abstract sealedpublic static class DataflowBlocktype DataflowBlock = classPublic Module DataflowBlock- Arv
-
DataflowBlock
Kommentarer
Note
TPL-dataflödesbiblioteket (System.Threading.Tasks.Dataflow-namnområdet) distribueras inte med .NET. Om du vill installera System.Threading.Tasks.Dataflow-namnområdet i Visual Studio öppnar du projektet, väljer Hantera NuGet-paket från menyn Project och söker online efter System.Threading.Tasks.Dataflow-paketet. Alternativt, för att installera det med hjälp av .NET Core CLI, kör dotnet add package System.Threading.Tasks.Dataflow.
Metoder
| Name | Description |
|---|---|
| AsObservable<TOutput>(ISourceBlock<TOutput>) |
Skapar en ny IObservable<T> abstraktion över ISourceBlock<TOutput>. |
| AsObserver<TInput>(ITargetBlock<TInput>) |
Skapar en ny IObserver<T> abstraktion över ITargetBlock<TInput>. |
| Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>, DataflowBlockOptions) |
Övervakar tre dataflödeskällor och anropar den angivna hanteraren för den källa som gör data tillgängliga först. |
| Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>) |
Övervakar tre dataflödeskällor och anropar den angivna hanteraren för den källa som gör data tillgängliga först. |
| Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, DataflowBlockOptions) |
Övervakar två dataflödeskällor och anropar den angivna hanteraren för den källa som gör data tillgängliga först. |
| Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>) |
Övervakar två dataflödeskällor och anropar den angivna hanteraren för den källa som gör data tillgängliga först. |
| Encapsulate<TInput,TOutput>(ITargetBlock<TInput>, ISourceBlock<TOutput>) |
Kapslar in ett mål och en källa i en enda spridning. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>) |
ISourceBlock<TOutput> Länkar till det angivna ITargetBlock<TInput> med det angivna filtret. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>) |
ISourceBlock<TOutput> Länkar till det angivna ITargetBlock<TInput> med det angivna filtret. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>) |
ISourceBlock<TOutput> Länkar till angiven ITargetBlock<TInput>. |
| NullTarget<TInput>() |
Hämtar ett målblock som synkront accepterar alla meddelanden som erbjuds till det och släpper dem. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Tillhandahåller en Task<TResult> som asynkront övervakar källan för tillgängliga utdata. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>) |
Tillhandahåller en Task<TResult> som asynkront övervakar källan för tillgängliga utdata. |
| Post<TInput>(ITargetBlock<TInput>, TInput) |
Publicerar ett objekt i ITargetBlock<TInput>. |
| Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Tar synkront emot ett värde från en angiven källa och tillhandahåller en token för att avbryta åtgärden. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Tar synkront emot ett värde från en angiven källa, vilket ger en token för att avbryta åtgärden och observerar ett valfritt tidsgränsintervall. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Tar synkront emot ett värde från en angiven källa och observerar en valfri tidsgräns. |
| Receive<TOutput>(ISourceBlock<TOutput>) |
Tar synkront emot ett värde från en angiven källa. |
| ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken) |
Skapar en IAsyncEnumerable<T> som gör det möjligt att ta emot alla data från källan. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Tar asynkront emot ett värde från en angiven källa och tillhandahåller en token för att avbryta åtgärden. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Asynkront tar emot ett värde från en angiven källa, vilket ger en token för att avbryta åtgärden och observera ett valfritt tidsgränsintervall. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Tar asynkront emot ett värde från en angiven källa och observerar en valfri tidsgräns. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>) |
Tar asynkront emot ett värde från en angiven källa. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken) |
Asynkront erbjuder ett meddelande till målmeddelandeblocket, vilket möjliggör senareläggning. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput) |
Asynkront erbjuder ett meddelande till målmeddelandeblocket, vilket möjliggör senareläggning. |
| TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput) |
Försöker ta emot ett objekt synkront från ISourceBlock<TOutput>. |
