TransformManyBlock<TInput,TOutput> Classe

Définition

Espace de noms:
System.Threading.Tasks.Dataflow
Assembly:
System.Threading.Tasks.Dataflow.dll
Paquet:
System.Threading.Tasks.Dataflow v11.0.0-preview.4.26230.115
Source:
TransformManyBlock.cs
Source:
TransformManyBlock.cs
Source:
TransformManyBlock.cs
Source:
TransformManyBlock.cs
Source:
TransformManyBlock.cs
Source:
TransformManyBlock.cs
Source:
TransformManyBlock.cs

Fournit un bloc de flux de données qui appelle un délégué fourni Func<T,TResult> 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çues et exploitées par ce TransformManyBlock<TInput,TOutput>paramètre .

TOutput

Spécifie le type de sortie de données par ce TransformManyBlock<TInput,TOutput>.

Héritage
Object
TransformManyBlock<TInput,TOutput>
Implémente
IDataflowBlock IPropagatorBlock<TInput,TOutput> IReceivableSourceBlock<TOutput> ISourceBlock<TOutput> ITargetBlock<TInput>

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.

Constructeurs

Nom Description
TransformManyBlock<TInput,TOutput>(Func<TInput,IAsyncEnumerable<TOutput>>, ExecutionDataflowBlockOptions)

Initialise avec TransformManyBlock<TInput,TOutput> la fonction spécifiée et ExecutionDataflowBlockOptions.
TransformManyBlock<TInput,TOutput>(Func<TInput,IAsyncEnumerable<TOutput>>)

Initialise la TransformManyBlock<TInput,TOutput> fonction spécifiée.
TransformManyBlock<TInput,TOutput>(Func<TInput,IEnumerable<TOutput>>, ExecutionDataflowBlockOptions)

Initialise un nouveau TransformManyBlock<TInput,TOutput> avec la fonction spécifiée et ExecutionDataflowBlockOptions.
TransformManyBlock<TInput,TOutput>(Func<TInput,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 spécifiée et ExecutionDataflowBlockOptions.
TransformManyBlock<TInput,TOutput>(Func<TInput,Task<IEnumerable<TOutput>>>)

Initialise une nouvelle TransformManyBlock<TInput,TOutput> avec la fonction spécifiée.

Propriétés

Nom Description
Completion

Obtient un 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 d’être traités par ce bloc.
OutputCount

Obtient le nombre d’éléments de sortie disponibles à recevoir à partir de ce bloc.

Méthodes

Nom Description
Complete()

Signale au IDataflowBlock fait qu’il ne doit pas accepter ni produire plus de messages ni consommer plus de messages reportés.
Equals(Object)

Détermine si l’objet spécifié est égal à l’objet actuel.

(Hérité de Object)
GetHashCode()

Sert de fonction de hachage par défaut.

(Hérité de Object)
GetType()

Obtient la Type de l’instance actuelle.

(Hérité de Object)
LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)

Lie le ISourceBlock<TOutput> fichier vers le fichier spécifié ITargetBlock<TInput> .
MemberwiseClone()

Crée une copie superficielle du Objectactuel.

(Hérité de Object)
ToString()

Retourne une chaîne qui représente le nom mis en forme de cette IDataflowBlock instance.
TryReceive(Predicate<TOutput>, TOutput)

Tente de recevoir de manière synchrone un élément de sortie disponible à partir du IReceivableSourceBlock<TOutput>.
TryReceiveAll(IList<TOutput>)

Tente de recevoir de manière synchrone tous les éléments disponibles à partir du IReceivableSourceBlock<TOutput>.

Implémentations d’interfaces explicites

Nom Description
IDataflowBlock.Fault(Exception)

Provoque la IDataflowBlock fin dans un Faulted état.
ISourceBlock<TOutput>.ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)

Appelé par un lié ITargetBlock<TInput> à accepter et consommer un DataflowMessageHeader précédemment proposé par ce ISourceBlock<TOutput>.
ISourceBlock<TOutput>.ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)

Appelé par un lien ITargetBlock<TInput> pour libérer un précédemment réservé DataflowMessageHeader par ce ISourceBlock<TOutput>.
ISourceBlock<TOutput>.ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)

Appelé par un lié ITargetBlock<TInput> à réserver un précédemment offert DataflowMessageHeader par ce ISourceBlock<TOutput>.
ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, Boolean)

Offre un message au ITargetBlock<TInput>, donnant à la cible la possibilité de consommer ou de reporter le message.

Méthodes d’extension

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>.
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>.
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>.

S’applique à