DataflowBlock Classe
Définition
Important
Certaines informations portent sur la préversion du produit qui est susceptible d’être en grande partie modifiée avant sa publication. Microsoft exclut toute garantie, expresse ou implicite, concernant les informations fournies ici.
Fournit un ensemble de méthodes statiques (partagées dans Visual Basic) pour utiliser des blocs de flux de données.
public ref class DataflowBlock abstract sealedpublic static class DataflowBlocktype DataflowBlock = classPublic Module DataflowBlock- Héritage
-
DataflowBlock
Remarques
Note
La bibliothèque de flux de données TPL (l’espace System.Threading.Tasks.Dataflow de noms) n’est pas distribuée avec .NET. Pour installer l’espace System.Threading.Tasks.Dataflow de noms dans Visual Studio, ouvrez votre projet, choisissez Gérer les packages NuGet dans le menu Projet et recherchez en ligne le System.Threading.Tasks.Dataflow package. Sinon, pour l’installer à l’aide de l’interface CLI .NET Core, exécutez dotnet add package System.Threading.Tasks.Dataflow.
Méthodes
| Nom | Description |
|---|---|
| AsObservable<TOutput>(ISourceBlock<TOutput>) |
Crée une IObservable<T> abstraction sur le ISourceBlock<TOutput>. |
| AsObserver<TInput>(ITargetBlock<TInput>) |
Crée une IObserver<T> abstraction sur le ITargetBlock<TInput>. |
| Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>, DataflowBlockOptions) |
Surveille trois sources de flux de données, appelant le gestionnaire fourni pour lequel la source rend les données disponibles en premier. |
| Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>) |
Surveille trois sources de flux de données, appelant le gestionnaire fourni pour lequel la source rend les données disponibles en premier. |
| Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, DataflowBlockOptions) |
Surveille deux sources de flux de données, en appelant le gestionnaire fourni pour lequel la source rend les données disponibles en premier. |
| Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>) |
Surveille deux sources de flux de données, en appelant le gestionnaire fourni pour lequel la source rend les données disponibles en premier. |
| Encapsulate<TInput,TOutput>(ITargetBlock<TInput>, ISourceBlock<TOutput>) |
Encapsule une cible et une source dans un seul propagateur. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>) |
Lie le ISourceBlock<TOutput> vers le filtre ITargetBlock<TInput> spécifié à l’aide du filtre spécifié. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>) |
Lie le ISourceBlock<TOutput> vers le filtre ITargetBlock<TInput> spécifié à l’aide du filtre spécifié. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>) |
Lie le ISourceBlock<TOutput> fichier vers le fichier spécifié ITargetBlock<TInput>. |
| NullTarget<TInput>() |
Obtient un bloc cible qui accepte de façon synchrone tous les messages qui lui sont proposés et les supprime. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Fournit un Task<TResult> moniteur asynchrone de la source pour la sortie disponible. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>) |
Fournit un Task<TResult> moniteur asynchrone de la source pour la sortie disponible. |
| Post<TInput>(ITargetBlock<TInput>, TInput) |
Publie un élément dans le ITargetBlock<TInput>. |
| Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Reçoit de façon synchrone une valeur d’une source spécifiée et fournit un jeton pour annuler l’opération. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Reçoit de façon synchrone une valeur d’une source spécifiée, fournissant un jeton pour annuler l’opération et observer un intervalle de délai d’attente facultatif. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Reçoit de façon synchrone une valeur d’une source spécifiée, en observant un délai d’attente facultatif. |
| Receive<TOutput>(ISourceBlock<TOutput>) |
Reçoit de façon synchrone une valeur d’une source spécifiée. |
| ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken) |
Crée un IAsyncEnumerable<T> qui permet de recevoir toutes les données de la source. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Reçoit de façon asynchrone une valeur d’une source spécifiée et fournit un jeton pour annuler l’opération. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Reçoit de façon asynchrone une valeur d’une source spécifiée, fournissant un jeton pour annuler l’opération et observer un intervalle de délai d’attente facultatif. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Reçoit de façon asynchrone une valeur d’une source spécifiée, en observant un délai d’attente facultatif. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>) |
Reçoit de façon asynchrone une valeur d’une source spécifiée. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken) |
Offre de façon asynchrone un message au bloc de message cible, ce qui permet un report. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput) |
Offre de façon asynchrone un message au bloc de message cible, ce qui permet un report. |
| TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput) |
Tente de recevoir de façon synchrone un élément à partir du ISourceBlock<TOutput>. |
