TransformManyBlock<TInput,TOutput> Clase

Definición

Espacio de nombres:: System.Threading.Tasks.Dataflow

Ensamblado:: System.Threading.Tasks.Dataflow.dll

Paquete:: System.Threading.Tasks.Dataflow v11.0.0-rc.1.26425.128

Source:: TransformManyBlock.cs

Source:: TransformManyBlock.cs

Source:: TransformManyBlock.cs

Source:: TransformManyBlock.cs

Source:: TransformManyBlock.cs

Source:: TransformManyBlock.cs

Source:: TransformManyBlock.cs

Source:: TransformManyBlock.cs

Importante

Parte de la información hace referencia a la versión preliminar del producto, que puede haberse modificado sustancialmente antes de lanzar la versión definitiva. Microsoft no otorga ninguna garantía, explícita o implícita, con respecto a la información proporcionada aquí.

Proporciona un bloque de flujo de datos que invoca un delegado proporcionado Func<T,TResult> para cada elemento de datos recibido.

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)

Parámetros de tipo

TInput

Especifica el tipo de datos recibidos y operados por este TransformManyBlock<TInput,TOutput>.

TOutput

Especifica el tipo de salida de datos por este TransformManyBlock<TInput,TOutput>.

Herencia: Object
TransformManyBlock<TInput,TOutput>

Implementaciones: IDataflowBlock IPropagatorBlock<TInput,TOutput> IReceivableSourceBlock<TOutput> ISourceBlock<TOutput> ITargetBlock<TInput>

Constructores

Nombre	Description
TransformManyBlock<TInput,TOutput>(Func<TInput,IAsyncEnumerable<TOutput>>, ExecutionDataflowBlockOptions)	Inicializa con TransformManyBlock<TInput,TOutput> la función especificada y ExecutionDataflowBlockOptions.
TransformManyBlock<TInput,TOutput>(Func<TInput,IAsyncEnumerable<TOutput>>)	Inicializa con TransformManyBlock<TInput,TOutput> la función especificada.
TransformManyBlock<TInput,TOutput>(Func<TInput,IEnumerable<TOutput>>, ExecutionDataflowBlockOptions)	Inicializa un nuevo TransformManyBlock<TInput,TOutput> con la función especificada y ExecutionDataflowBlockOptions.
TransformManyBlock<TInput,TOutput>(Func<TInput,IEnumerable<TOutput>>)	Inicializa un nuevo TransformManyBlock<TInput,TOutput> con la función especificada.
TransformManyBlock<TInput,TOutput>(Func<TInput,Task<IEnumerable<TOutput>>>, ExecutionDataflowBlockOptions)	Inicializa un nuevo TransformManyBlock<TInput,TOutput> con la función especificada y ExecutionDataflowBlockOptions.
TransformManyBlock<TInput,TOutput>(Func<TInput,Task<IEnumerable<TOutput>>>)	Inicializa un nuevo TransformManyBlock<TInput,TOutput> con la función especificada.

Propiedades

Nombre	Description
Completion	Obtiene un Task objeto que representa la operación asincrónica y la finalización del bloque de flujo de datos.
InputCount	Obtiene el número de elementos de entrada que esperan ser procesados por este bloque.
OutputCount	Obtiene el número de elementos de salida disponibles para recibirse de este bloque.

Métodos

Nombre	Description
Complete()	Señala a que IDataflowBlock no debe aceptar ni producir más mensajes ni consumir más mensajes pospuestos.
Equals(Object)	Determina si el objeto especificado es igual al objeto actual. (Heredado de Object)
GetHashCode()	Actúa como función hash predeterminada. (Heredado de Object)
GetType()	Obtiene el Type de la instancia actual. (Heredado de Object)
LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)	Vincula al ISourceBlock<TOutput> objeto especificado ITargetBlock<TInput> .
MemberwiseClone()	Crea una copia superficial del Objectactual. (Heredado de Object)
ToString()	Devuelve una cadena que representa el nombre con formato de esta IDataflowBlock instancia.
TryReceive(Predicate<TOutput>, TOutput)	Intenta recibir de forma sincrónica un elemento de salida disponible de .IReceivableSourceBlock<TOutput>
TryReceiveAll(IList<TOutput>)	Intenta recibir de forma sincrónica todos los elementos disponibles de IReceivableSourceBlock<TOutput>.

Implementaciones de interfaz explícitas

Nombre	Description
IDataflowBlock.Fault(Exception)	Hace que se IDataflowBlock complete en un Faulted estado .
ISourceBlock<TOutput>.ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)	Llamado por un vinculado ITargetBlock<TInput> para aceptar y consumir un DataflowMessageHeader objeto previamente ofrecido por este ISourceBlock<TOutput>.
ISourceBlock<TOutput>.ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)	Llamado por un vinculado ITargetBlock<TInput> para liberar un objeto reservado DataflowMessageHeader previamente por este ISourceBlock<TOutput>.
ISourceBlock<TOutput>.ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)	Llamado por un vinculado ITargetBlock<TInput> para reservar un objeto ofrecido DataflowMessageHeader anteriormente por este ISourceBlock<TOutput>.
ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, Boolean)	Ofrece un mensaje a , ITargetBlock<TInput>lo que proporciona al destino la oportunidad de consumir o posponer el mensaje.

Métodos de extensión

Nombre	Description
AsObservable<TOutput>(ISourceBlock<TOutput>)	Crea una nueva IObservable<T> abstracción sobre .ISourceBlock<TOutput>
AsObserver<TInput>(ITargetBlock<TInput>)	Crea una nueva IObserver<T> abstracción sobre .ITargetBlock<TInput>
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)	ISourceBlock<TOutput> Vincula al especificado ITargetBlock<TInput> mediante el filtro especificado.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)	ISourceBlock<TOutput> Vincula al especificado ITargetBlock<TInput> mediante el filtro especificado.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	Vincula al ISourceBlock<TOutput> objeto especificado ITargetBlock<TInput>.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Proporciona un objeto Task<TResult> que supervisa de forma asincrónica el origen de la salida disponible.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	Proporciona un objeto Task<TResult> que supervisa de forma asincrónica el origen de la salida disponible.
Post<TInput>(ITargetBlock<TInput>, TInput)	Publica un elemento en .ITargetBlock<TInput>
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Recibe sincrónicamente un valor de un origen especificado y proporciona un token para cancelar la operación.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Recibe sincrónicamente un valor de un origen especificado, proporcionando un token para cancelar la operación y observar un intervalo de tiempo de espera opcional.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Recibe sincrónicamente un valor de un origen especificado, observando un período de tiempo de espera opcional.
Receive<TOutput>(ISourceBlock<TOutput>)	Recibe sincrónicamente un valor de un origen especificado.
ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)	Crea un objeto IAsyncEnumerable<T> que permite recibir todos los datos del origen.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Recibe de forma asincrónica un valor de un origen especificado y proporciona un token para cancelar la operación.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Recibe de forma asincrónica un valor de un origen especificado, lo que proporciona un token para cancelar la operación y observar un intervalo de tiempo de espera opcional.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Recibe de forma asincrónica un valor de un origen especificado, observando un período de tiempo de espera opcional.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	Recibe de forma asincrónica un valor de un origen especificado.
SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken)	Ofrece de forma asincrónica un mensaje al bloque de mensajes de destino, lo que permite posponer.
SendAsync<TInput>(ITargetBlock<TInput>, TInput)	Ofrece de forma asincrónica un mensaje al bloque de mensajes de destino, lo que permite posponer.
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)	Intenta recibir de forma sincrónica un elemento de .ISourceBlock<TOutput>

Se aplica a

Comentarios

¿Le ha resultado útil esta página?