DataflowBlock Klas
Definitie
Belangrijk
Bepaalde informatie heeft betrekking op een voorlopige productversie die aanzienlijk kan worden gewijzigd voordat deze wordt uitgebracht. Microsoft biedt geen enkele expliciete of impliciete garanties met betrekking tot de informatie die hier wordt verstrekt.
Biedt een set statische methoden (gedeeld in Visual Basic) voor het werken met gegevensstroomblokken.
public ref class DataflowBlock abstract sealedpublic static class DataflowBlocktype DataflowBlock = classPublic Module DataflowBlock- Overname
-
DataflowBlock
Opmerkingen
Note
De TPL-gegevensstroombibliotheek (de System.Threading.Tasks.Dataflow naamruimte) wordt niet gedistribueerd met .NET. Als u de System.Threading.Tasks.Dataflow-naamruimte in Visual Studio wilt installeren, opent u uw project, kiest u NuGet-pakketten beheren in het menu Project en zoekt u online naar het System.Threading.Tasks.Dataflow-pakket. Om deze te installeren met behulp van de .NET Core CLI, voert u dotnet add package System.Threading.Tasks.Dataflowuit.
Methoden
| Name | Description |
|---|---|
| AsObservable<TOutput>(ISourceBlock<TOutput>) |
Hiermee maakt u een nieuwe IObservable<T> abstractie over de ISourceBlock<TOutput>. |
| AsObserver<TInput>(ITargetBlock<TInput>) |
Hiermee maakt u een nieuwe IObserver<T> abstractie over de ITargetBlock<TInput>. |
| Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>, DataflowBlockOptions) |
Controleert drie gegevensstroombronnen, waarbij de opgegeven handler wordt aanroepen voor de gegevensbron die eerst beschikbaar is. |
| Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>) |
Controleert drie gegevensstroombronnen, waarbij de opgegeven handler wordt aanroepen voor de gegevensbron die eerst beschikbaar is. |
| Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, DataflowBlockOptions) |
Bewaakt twee gegevensstroombronnen, waarbij de meegeleverde handler wordt aanroepen voor de gegevensbron die eerst beschikbaar is. |
| Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>) |
Bewaakt twee gegevensstroombronnen, waarbij de meegeleverde handler wordt aanroepen voor de gegevensbron die eerst beschikbaar is. |
| Encapsulate<TInput,TOutput>(ITargetBlock<TInput>, ISourceBlock<TOutput>) |
Een doel en een bron inkapselen in één doorgifteprogramma. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>) |
Hiermee koppelt u de ISourceBlock<TOutput> opgegeven aan de opgegeven ITargetBlock<TInput> met behulp van het opgegeven filter. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>) |
Hiermee koppelt u de ISourceBlock<TOutput> opgegeven aan de opgegeven ITargetBlock<TInput> met behulp van het opgegeven filter. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>) |
Hiermee koppelt u de ISourceBlock<TOutput> opgegeven ITargetBlock<TInput>. |
| NullTarget<TInput>() |
Hiermee haalt u een doelblok op dat synchroon alle aangeboden berichten accepteert en deze verwijdert. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Biedt een Task<TResult> die asynchroon de bron bewaakt voor beschikbare uitvoer. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>) |
Biedt een Task<TResult> die asynchroon de bron bewaakt voor beschikbare uitvoer. |
| Post<TInput>(ITargetBlock<TInput>, TInput) |
Hiermee plaatst u een item in de ITargetBlock<TInput>. |
| Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Synchroon ontvangt een waarde van een opgegeven bron en biedt een token om de bewerking te annuleren. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Synchroon ontvangt een waarde van een opgegeven bron, waardoor een token wordt opgegeven om de bewerking te annuleren en een optioneel time-outinterval te observeren. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Synchroon ontvangt een waarde van een opgegeven bron, waarbij een optionele time-outperiode wordt waargenomen. |
| Receive<TOutput>(ISourceBlock<TOutput>) |
Hiermee ontvangt u synchroon een waarde van een opgegeven bron. |
| ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken) |
Hiermee maakt u een IAsyncEnumerable<T> bestand waarmee alle gegevens van de bron kunnen worden ontvangen. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Asynchroon ontvangt een waarde van een opgegeven bron en biedt een token om de bewerking te annuleren. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Asynchroon ontvangt een waarde van een opgegeven bron, waarbij een token wordt opgegeven om de bewerking te annuleren en een optioneel time-outinterval te observeren. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Asynchroon ontvangt een waarde van een opgegeven bron, waarbij een optionele time-outperiode wordt waargenomen. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>) |
Asynchroon ontvangt een waarde van een opgegeven bron. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken) |
Asynchroon biedt een bericht aan het doelberichtblok, waardoor uitstel mogelijk is. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput) |
Asynchroon biedt een bericht aan het doelberichtblok, waardoor uitstel mogelijk is. |
| TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput) |
Pogingen om een item synchroon te ontvangen van de ISourceBlock<TOutput>. |
