IPropagatorBlock<TInput,TOutput> Interface

Definição

Espaço de Nomes:: System.Threading.Tasks.Dataflow

Assemblagem:: System.Threading.Tasks.Dataflow.dll

Importante

Algumas informações dizem respeito a um produto pré-lançado que pode ser substancialmente modificado antes de ser lançado. A Microsoft não faz garantias, de forma expressa ou implícita, em relação à informação aqui apresentada.

Representa um bloco de fluxo de dados que é simultaneamente alvo de dados e fonte de dados.

generic <typename TInput, typename TOutput>
public interface class IPropagatorBlock : System::Threading::Tasks::Dataflow::ISourceBlock<TOutput>, System::Threading::Tasks::Dataflow::ITargetBlock<TInput>

public interface IPropagatorBlock<in TInput,out TOutput> : System.Threading.Tasks.Dataflow.ISourceBlock<out TOutput>, System.Threading.Tasks.Dataflow.ITargetBlock<in TInput>

type IPropagatorBlock<'Input, 'Output> = interface
    interface ITargetBlock<'Input>
    interface IDataflowBlock
    interface ISourceBlock<'Output>

Public Interface IPropagatorBlock(Of In TInput, Out TOutput)
Implements ISourceBlock(Of Out TOutput), ITargetBlock(Of In TInput)

Parâmetros de Tipo Genérico

TInput

Especifica o tipo de dados aceites pelo IPropagatorBlock<TInput,TOutput>.

Este parâmetro de tipo é contravariante. Ou seja, pode utilizar o tipo que especificou ou qualquer tipo que seja menos derivado. Para obter mais informações sobre covariância e contravariância, veja Covariância e Contravariância em Genérico.

TOutput

Especifica o tipo de dados fornecidos pelo IPropagatorBlock<TInput,TOutput>.

Este parâmetro de tipo é covariante. Ou seja, pode utilizar o tipo que especificou ou qualquer tipo que seja mais derivado. Para obter mais informações sobre covariância e contravariância, veja Covariância e Contravariância em Genérico.

Derivado: System.Threading.Tasks.Dataflow.BatchBlock<T>

System.Threading.Tasks.Dataflow.BroadcastBlock<T>

System.Threading.Tasks.Dataflow.BufferBlock<T>

System.Threading.Tasks.Dataflow.TransformBlock<TInput,TOutput>

System.Threading.Tasks.Dataflow.TransformManyBlock<TInput,TOutput>

Mais…

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

Observações

Note

A biblioteca de fluxo de dados TPL (o namespace System.Threading.Tasks.Dataflow) não é distribuída com o .NET. Para instalar o namespace System.Threading.Tasks.Dataflow no Visual Studio, abra o seu projeto, escolha Gerir Pacotes NuGet no menu Projeto e pesquise o pacote System.Threading.Tasks.Dataflow online. Como alternativa, para instalá-lo usando a CLI do .NET Core, execute dotnet add package System.Threading.Tasks.Dataflow.

Propriedades

Name	Description
Completion	Obtém-se a Task que representa a operação assíncrona e a conclusão do bloco de fluxo de dados. (Herdado de IDataflowBlock)

Métodos

Name	Description
Complete()	Sinais para o IDataflowBlock grupo de que não deve aceitar nem produzir mais mensagens nem consumir mais mensagens adiadas. (Herdado de IDataflowBlock)
ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)	Chamado por um link ITargetBlock<TInput> para aceitar e consumir um DataflowMessageHeader anteriormente oferecido por este ISourceBlock<TOutput>. (Herdado de ISourceBlock<TOutput>)
Fault(Exception)	Faz com que a IDataflowBlock conclua num Faulted estado. (Herdado de IDataflowBlock)
LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)	Liga o ISourceBlock<TOutput> ao especificado ITargetBlock<TInput>. (Herdado de ISourceBlock<TOutput>)
OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, Boolean)	Oferece uma mensagem ao ITargetBlock<TInput>, dando ao alvo a oportunidade de consumir ou adiar a mensagem. (Herdado de ITargetBlock<TInput>)
ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)	Chamado por um link ITargetBlock<TInput> para libertar um anteriormente reservado DataflowMessageHeader por este ISourceBlock<TOutput>. (Herdado de ISourceBlock<TOutput>)
ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)	Chamado por um ligado ITargetBlock<TInput> para reservar um já oferecido DataflowMessageHeader por isto ISourceBlock<TOutput>. (Herdado de ISourceBlock<TOutput>)

Métodos da Extensão

Name	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>)	Liga o ISourceBlock<TOutput> ao especificado ITargetBlock<TInput> usando o filtro especificado.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)	Liga o ISourceBlock<TOutput> ao especificado ITargetBlock<TInput> usando o filtro especificado.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	Liga o ISourceBlock<TOutput> ao especificado ITargetBlock<TInput>.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Fornece um Task<TResult> que monitoriza assíncronamente a fonte para a saída disponível.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	Fornece um Task<TResult> que monitoriza assíncronamente a fonte para a saída disponível.
Post<TInput>(ITargetBlock<TInput>, TInput)	Publica um item no ITargetBlock<TInput>arquivo .
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)	O Synchroniously recebe um valor de uma fonte especificada e fornece um token para cancelar a operação.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Synchronally recebe um valor de uma fonte especificada, fornecendo um token para cancelar a operação e observando um intervalo opcional de time-out.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Sincronizadamente recebe um valor de uma fonte especificada, observando um período opcional de time-out.
Receive<TOutput>(ISourceBlock<TOutput>)	Recebe síncronicamente um valor de uma fonte especificada.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	De forma assíncrona, recebe um valor de uma fonte especificada e fornece um token para cancelar a operação.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	De forma assíncrona, recebe um valor de uma fonte especificada, fornecendo um token para cancelar a operação e observando um intervalo opcional de time-out.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)	De forma assíncrona, recebe um valor de uma fonte especificada, observando um período opcional de time-out.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	De forma assíncrona, recebe um valor de uma fonte especificada.
SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken)	Assíncrono, oferece uma mensagem ao bloco de mensagens alvo, permitindo adiamento.
SendAsync<TInput>(ITargetBlock<TInput>, TInput)	Assíncrono, oferece uma mensagem ao bloco de mensagens alvo, permitindo adiamento.

Aplica-se a

Comentários

Esta página foi útil?