TransformManyBlock<TInput,TOutput> 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 bloc de flux de données qui appelle un délégué Func<T,TResult> fourni pour chaque élément de données reçu.
generic <typename TInput, typename TOutput>
public ref class TransformManyBlock sealed : System::Threading::Tasks::Dataflow::IPropagatorBlock<TInput, TOutput>, System::Threading::Tasks::Dataflow::IReceivableSourceBlock<TOutput>, System::Threading::Tasks::Dataflow::ISourceBlock<TOutput>, System::Threading::Tasks::Dataflow::ITargetBlock<TInput>public sealed class TransformManyBlock<TInput,TOutput> : System.Threading.Tasks.Dataflow.IPropagatorBlock<TInput,TOutput>, System.Threading.Tasks.Dataflow.IReceivableSourceBlock<TOutput>, System.Threading.Tasks.Dataflow.ISourceBlock<TOutput>, System.Threading.Tasks.Dataflow.ITargetBlock<TInput>type TransformManyBlock<'Input, 'Output> = class
interface IPropagatorBlock<'Input, 'Output>
interface ITargetBlock<'Input>
interface IDataflowBlock
interface ISourceBlock<'Output>
interface IReceivableSourceBlock<'Output>type TransformManyBlock<'Input, 'Output> = class
interface IDataflowBlock
interface IPropagatorBlock<'Input, 'Output>
interface ISourceBlock<'Output>
interface ITargetBlock<'Input>
interface IReceivableSourceBlock<'Output>Public NotInheritable Class TransformManyBlock(Of TInput, TOutput)
Implements IPropagatorBlock(Of TInput, TOutput), IReceivableSourceBlock(Of TOutput), ISourceBlock(Of TOutput), ITargetBlock(Of TInput)Paramètres de type
- TInput
Spécifie le type de données reçu et traité par ce TransformManyBlock<TInput,TOutput>.
- TOutput
Spécifie le type de données généré par le TransformManyBlock<TInput,TOutput>.
- Héritage
-
TransformManyBlock<TInput,TOutput>
- Implémente
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.
Constructeurs
| TransformManyBlock<TInput,TOutput>(Func<TInput,IEnumerable<TOutput>>) |
Initialise une nouvelle TransformManyBlock<TInput,TOutput> avec la fonction spécifiée. |
| TransformManyBlock<TInput,TOutput>(Func<TInput,IEnumerable<TOutput>>, ExecutionDataflowBlockOptions) |
Initialise un nouveau TransformManyBlock<TInput,TOutput> avec la fonction et ExecutionDataflowBlockOptions spécifiés. |
| TransformManyBlock<TInput,TOutput>(Func<TInput,Task<IEnumerable<TOutput>>>) |
Initialise une nouvelle TransformManyBlock<TInput,TOutput> avec la fonction spécifiée. |
| TransformManyBlock<TInput,TOutput>(Func<TInput,Task<IEnumerable<TOutput>>>, ExecutionDataflowBlockOptions) |
Initialise un nouveau TransformManyBlock<TInput,TOutput> avec la fonction et ExecutionDataflowBlockOptions spécifiés. |
Propriétés
| Completion |
Obtient une Task qui représente l'opération asynchrone et l'achèvement du bloc de flux de données. |
| InputCount |
Obtient le nombre d'éléments d'entrée en attente de traitement par ce bloc. |
| OutputCount |
Obtient le nombre d'éléments de sortie disponibles en provenance de ce bloc. |
Méthodes
| Complete() |
Signale à IDataflowBlock qu'il ne doit plus recevoir ni produire de messages ou utiliser des messages différés. |
| Equals(Object) |
Détermine si l'objet spécifié est égal à l'objet actuel. (Hérité de Object) |
| GetHashCode() |
Fait office de fonction de hachage par défaut. (Hérité de Object) |
| GetType() |
Obtient le Type de l'instance actuelle. (Hérité de Object) |
| LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions) |
Lie le ISourceBlock<TOutput> au ITargetBlock<TInput> spécifié. |
| MemberwiseClone() |
Crée une copie superficielle du Object actuel. (Hérité de Object) |
| ToString() |
Retourne une chaîne qui représente le nom mis en forme de cette instance de IDataflowBlock. |
| TryReceive(Predicate<TOutput>, TOutput) |
Tente de recevoir de façon synchrone un élément de sortie disponible de IReceivableSourceBlock<TOutput>. |
| TryReceiveAll(IList<TOutput>) |
Tente de recevoir de façon synchrone tous les éléments disponibles de IReceivableSourceBlock<TOutput>. |
Implémentations d’interfaces explicites
| IDataflowBlock.Fault(Exception) |
Provoque l’achèvement du IDataflowBlock à l’état Faulted. |
| ISourceBlock<TOutput>.ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean) |
Appelé par un ITargetBlock<TInput> lié pour recevoir et utiliser un DataflowMessageHeader précédemment proposé par ce ISourceBlock<TOutput>. |
| ISourceBlock<TOutput>.ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>) |
Appelé par un ITargetBlock<TInput> lié pour libérer un DataflowMessageHeader précédemment réservé par ce ISourceBlock<TOutput>. |
| ISourceBlock<TOutput>.ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>) |
Appelé par un ITargetBlock<TInput> lié pour réserver un DataflowMessageHeader précédemment proposé par ce ISourceBlock<TOutput>. |
| ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, Boolean) |
Offre un message au ITargetBlock<TInput>, donnant à la cible la possibilité d'utiliser ou de différer le message. |
Méthodes d’extension
| 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>. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>) |
Lie le ISourceBlock<TOutput> au ITargetBlock<TInput> 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é. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>) |
Lie le ISourceBlock<TOutput> au ITargetBlock<TInput> spécifié à l’aide du filtre spécifié. |
| 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>. |