ISourceBlock<TOutput> Interface

Definição

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

Representa um bloco de fluxo de dados que é uma fonte de dados.

generic <typename TOutput>
public interface class ISourceBlock : System::Threading::Tasks::Dataflow::IDataflowBlock
public interface ISourceBlock<out TOutput> : System.Threading.Tasks.Dataflow.IDataflowBlock
type ISourceBlock<'Output> = interface
    interface IDataflowBlock
Public Interface ISourceBlock(Of Out TOutput)
Implements IDataflowBlock

Parâmetros de Tipo Genérico

TOutput

Especifica o tipo de dados fornecidos pelo ISourceBlock<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
Implementações
IDataflowBlock

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>.
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>.
ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)

Chamado por um link ITargetBlock<TInput> para libertar um anteriormente reservado DataflowMessageHeader por este ISourceBlock<TOutput>.
ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)

Chamado por um ligado ITargetBlock<TInput> para reservar um já oferecido DataflowMessageHeader por isto ISourceBlock<TOutput>.

Métodos da Extensão

Name Description
AsObservable<TOutput>(ISourceBlock<TOutput>)

Cria uma nova IObservable<T> abstração sobre o ISourceBlock<TOutput>.
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.
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.

Aplica-se a