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 (Shared en 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
Notes
La bibliothèque de flux de données TPL (espace de noms System.Threading.Tasks.Dataflow) n'est pas distribuée avec .NET. Pour installer l’espace de noms System.Threading.Tasks.Dataflow dans Visual Studio, ouvrez votre projet, choisissez Gérer les packages NuGet dans le menu Projet, puis recherchez en ligne le package System.Threading.Tasks.Dataflow. Vous pouvez également l’installer à l’aide de l’interface CLI .NET Core en exécutant dotnet add package System.Threading.Tasks.Dataflow.
Méthodes
| AsObservable<TOutput>(ISourceBlock<TOutput>) |
Crée une abstraction IObservable<T> sur ISourceBlock<TOutput>. |
| AsObserver<TInput>(ITargetBlock<TInput>) |
Crée une abstraction IObserver<T> sur ITargetBlock<TInput>. |
| Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>) |
Surveille trois sources de flux de données, en appelant le gestionnaire fourni pour toute source qui rend les données disponibles en premier. |
| 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, en appelant le gestionnaire fourni pour toute source qui 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 toute source qui 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 toute source qui rend les données disponibles en premier. |
| Encapsulate<TInput,TOutput>(ITargetBlock<TInput>, ISourceBlock<TOutput>) |
Encapsule une cible et une source dans un propagateur unique. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>) |
Lie le ISourceBlock<TOutput> au ITargetBlock<TInput> spécifié. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>) |
Lie le ISourceBlock<TOutput> au ITargetBlock<TInput> spécifié à l’aide du filtre spécifié. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>) |
Lie le ISourceBlock<TOutput> au ITargetBlock<TInput> spécifié à l’aide du filtre spécifié. |
| NullTarget<TInput>() |
Obtient un bloc cible qui reçoit de façon synchrone tous les messages fournis à ce dernier et les supprime. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>) |
Fournit un Task<TResult> qui surveille de façon asynchrone la source de la sortie disponible. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Fournit un Task<TResult> qui surveille de façon asynchrone la source de la sortie disponible. |
| Post<TInput>(ITargetBlock<TInput>, TInput) |
Publie un élément à ITargetBlock<TInput>. |
| Receive<TOutput>(ISourceBlock<TOutput>) |
Reçoit de façon synchrone une valeur d'une source spécifiée. |
| 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) |
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>, TimeSpan, CancellationToken) |
Reçoit de façon synchrone une valeur d'une source spécifiée, en fournissant un jeton pour annuler l'opération et en observant un délai d'attente facultatif. |
| 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>) |
Reçoit de façon asynchrone une valeur d'une source spécifiée. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Accepte 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) |
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>, TimeSpan, CancellationToken) |
Reçoit de façon asynchrone une valeur d'une source spécifiée, en fournissant un jeton pour annuler l'opération et en observant un délai d'attente facultatif. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput) |
Propose de façon asynchrone un message au bloc de message cible, en autorisant l'ajournement. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken) |
Propose de façon asynchrone un message au bloc de message cible, en autorisant l'ajournement. |
| TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput) |
Tente de recevoir de façon synchrone un élément de ISourceBlock<TOutput>. |