TransformBlock<TInput,TOutput> Classe

Definição

Namespace:: System.Threading.Tasks.Dataflow

Assembly:: System.Threading.Tasks.Dataflow.dll

Importante

Algumas informações se referem a produtos de pré-lançamento que podem ser substancialmente modificados antes do lançamento. A Microsoft não oferece garantias, expressas ou implícitas, das informações aqui fornecidas.

Fornece um bloco de fluxo de dados que invoca um delegado fornecido Func<T,TResult> para cada elemento de dados recebido.

generic <typename TInput, typename TOutput>
public ref class TransformBlock 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 TransformBlock<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 TransformBlock<'Input, 'Output> = class
    interface IPropagatorBlock<'Input, 'Output>
    interface ITargetBlock<'Input>
    interface IDataflowBlock
    interface ISourceBlock<'Output>
    interface IReceivableSourceBlock<'Output>

Public NotInheritable Class TransformBlock(Of TInput, TOutput)
Implements IPropagatorBlock(Of TInput, TOutput), IReceivableSourceBlock(Of TOutput), ISourceBlock(Of TOutput), ITargetBlock(Of TInput)

Parâmetros de tipo

TInput

Especifica o tipo de dados recebidos e operados por este TransformBlock<TInput,TOutput>.

TOutput

Especifica o tipo de saída de dados por isso TransformBlock<TInput,TOutput>.

Herança: Object
TransformBlock<TInput,TOutput>

Implementações: IDataflowBlock IPropagatorBlock<TInput,TOutput> IReceivableSourceBlock<TOutput> ISourceBlock<TOutput> ITargetBlock<TInput>

Comentários

Note

A Biblioteca de Fluxo de Dados TPL (o namespace System.Threading.Tasks.Dataflow) não é distribuída com .NET. Para instalar o namespace System.Threading.Tasks.Dataflow no Visual Studio, abra seu projeto, escolha Gerenciar Pacotes NuGet no menu do Projeto e pesquise online o pacote System.Threading.Tasks.Dataflow. Como alternativa, instale-o usando a CLI do .NET Core e execute dotnet add package System.Threading.Tasks.Dataflow.

Construtores

Nome	Description
TransformBlock<TInput,TOutput>(Func<TInput,Task<TOutput>>, ExecutionDataflowBlockOptions)	Inicializa um novo TransformBlock<TInput,TOutput> com o especificado Func<T,TResult> e ExecutionDataflowBlockOptions.
TransformBlock<TInput,TOutput>(Func<TInput,Task<TOutput>>)	Inicializa um novo TransformBlock<TInput,TOutput> com o especificado Func<T,TResult>.
TransformBlock<TInput,TOutput>(Func<TInput,TOutput>, ExecutionDataflowBlockOptions)	Inicializa um novo TransformBlock<TInput,TOutput> com o especificado Func<T,TResult> e ExecutionDataflowBlockOptions.
TransformBlock<TInput,TOutput>(Func<TInput,TOutput>)	Inicializa um novo TransformBlock<TInput,TOutput> com o especificado Func<T,TResult>.

Propriedades

Nome	Description
Completion	Obtém um Task que representa a operação assíncrona e a conclusão do bloco de fluxo de dados.
InputCount	Obtém o número de itens de entrada que estão aguardando para serem processados por esse bloco.
OutputCount	Obtém o número de itens de saída disponíveis para serem recebidos desse bloco.

Métodos

Nome	Description
Complete()	Sinaliza para IDataflowBlock que ele não deve aceitar nem produzir mais mensagens nem consumir mais mensagens adiadas.
Equals(Object)	Determina se o objeto especificado é igual ao objeto atual. (Herdado de Object)
GetHashCode()	Serve como a função hash predefinida. (Herdado de Object)
GetType()	Obtém o Type da instância atual. (Herdado de Object)
LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)	Vincula o ISourceBlock<TOutput> link para o especificado ITargetBlock<TInput> .
MemberwiseClone()	Cria uma cópia superficial do Objectatual. (Herdado de Object)
ToString()	Retorna uma cadeia de caracteres que representa o nome formatado dessa IDataflowBlock instância.
TryReceive(Predicate<TOutput>, TOutput)	Tenta receber de forma síncrona um item de saída disponível do IReceivableSourceBlock<TOutput>.
TryReceiveAll(IList<TOutput>)	Tenta receber síncronamente todos os itens disponíveis do IReceivableSourceBlock<TOutput>.

Implantações explícitas de interface

Nome	Description
IDataflowBlock.Fault(Exception)	Faz com que a IDataflowBlock conclusão seja concluída em um Faulted estado.
ISourceBlock<TOutput>.ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)	Chamado por um vinculado ITargetBlock<TInput> para aceitar e consumir um DataflowMessageHeader oferecido anteriormente por isso ISourceBlock<TOutput>.
ISourceBlock<TOutput>.ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)	Chamado por um vinculado ITargetBlock<TInput> para liberar um anteriormente reservado DataflowMessageHeader por este ISourceBlock<TOutput>.
ISourceBlock<TOutput>.ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)	Chamado por um vinculado ITargetBlock<TInput> para reservar um oferecido DataflowMessageHeader anteriormente por isso ISourceBlock<TOutput>.
ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, Boolean)	Oferece uma mensagem para o ITargetBlock<TInput>destino, dando ao destino a oportunidade de consumir ou adiar a mensagem.

Métodos de Extensão

Nome	Description
AsObservable<TOutput>(ISourceBlock<TOutput>)	Cria uma nova IObservable<T> abstração sobre o ISourceBlock<TOutput>.
AsObserver<TInput>(ITargetBlock<TInput>)	Cria uma nova IObserver<T> abstração sobre o ITargetBlock<TInput>.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)	Vincula o ISourceBlock<TOutput> arquivo ao especificado ITargetBlock<TInput> usando o filtro especificado.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)	Vincula o ISourceBlock<TOutput> arquivo ao especificado ITargetBlock<TInput> usando o filtro especificado.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	Vincula o ISourceBlock<TOutput> link para o especificado ITargetBlock<TInput>.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Fornece um Task<TResult> que monitora assíncronamente a origem da saída disponível.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	Fornece um Task<TResult> que monitora assíncronamente a origem da saída disponível.
Post<TInput>(ITargetBlock<TInput>, TInput)	Posta um item no ITargetBlock<TInput>.
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Recebe de forma síncrona um valor de uma origem especificada e fornece um token para cancelar a operação.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Recebe de forma síncrona um valor de uma origem especificada, fornecendo um token para cancelar a operação e observando um intervalo de tempo limite opcional.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Recebe de forma síncrona um valor de uma origem especificada, observando um período de tempo limite opcional.
Receive<TOutput>(ISourceBlock<TOutput>)	Recebe de forma síncrona um valor de uma origem especificada.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Recebe de forma assíncrona um valor de uma origem especificada e fornece um token para cancelar a operação.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Recebe de forma assíncrona um valor de uma origem especificada, fornecendo um token para cancelar a operação e observando um intervalo de tempo limite opcional.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Recebe de forma assíncrona um valor de uma origem especificada, observando um período de tempo limite opcional.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	Recebe de forma assíncrona um valor de uma origem especificada.
SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken)	Oferece de forma assíncrona uma mensagem para o bloco de mensagens de destino, permitindo o adiamento.
SendAsync<TInput>(ITargetBlock<TInput>, TInput)	Oferece de forma assíncrona uma mensagem para o bloco de mensagens de destino, permitindo o adiamento.
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)	Tenta receber um item de forma síncrona do ISourceBlock<TOutput>.

Aplica-se a

Comentários

Esta página foi útil?