Compartilhar via

ISourceBlock<TOutput> Interface

  • Referência

Definição

Namespace:
System.Threading.Tasks.Dataflow
Assembly:
System.Threading.Tasks.Dataflow.dll
Pacote:
System.Threading.Tasks.Dataflow v8.0.0
Pacote:
System.Threading.Tasks.Dataflow v9.0.0-preview.4.24266.19

Representa um bloco de fluxo de dados que é uma origem 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

TOutput

Especifica o tipo de dados fornecidos ISourceBlock<TOutput>pelo .

Este parâmetro de tipo é covariante. Isso significa que é possível usar o tipo especificado ou qualquer tipo mais derivado. Para obter mais informações sobre covariância e contravariância, consulte Covariância e contravariância em genéricos.
Derivado
Implementações
IDataflowBlock

Comentários

Observação

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 projeto, escolha Gerenciar Pacotes NuGet no menu 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.

Propriedades

Completion

Obtém um Task que representa a operação assíncrona e a conclusão do bloco de fluxo de dados.

(Herdado de IDataflowBlock)

Métodos

Complete()

Sinaliza para o IDataflowBlock que ele não deve aceitar nem produzir mais mensagens, e não deve consumir mais mensagens adiadas.

(Herdado de IDataflowBlock)
ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)

Chamado por um ITargetBlock<TInput> vinculado para aceitar e consumir um DataflowMessageHeader anteriormente oferecido por este ISourceBlock<TOutput>.
Fault(Exception)

Faz com que o IDataflowBlock seja concluído em um estado Faulted.

(Herdado de IDataflowBlock)
LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)

Vincula o ISourceBlock<TOutput> ao especificado ITargetBlock<TInput>.
ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)

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

Chamado por um ITargetBlock<TInput> vinculado para reservar um DataflowMessageHeader oferecido anteriormente por este ISourceBlock<TOutput>.

Métodos de Extensão

AsObservable<TOutput>(ISourceBlock<TOutput>)

Cria uma nova abstração IObservable<T> em relação a ISourceBlock<TOutput>.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)

Vincula o ISourceBlock<TOutput> ao especificado ITargetBlock<TInput>.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)

Vincula o ISourceBlock<TOutput> ao especificado ITargetBlock<TInput> usando o filtro especificado.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)

Vincula o ISourceBlock<TOutput> ao especificado ITargetBlock<TInput> usando o filtro especificado.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)

Fornece um Task<TResult> que monitora assincronamente a saída disponível na fonte.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)

Fornece um Task<TResult> que monitora assincronamente a saída disponível na fonte.
Receive<TOutput>(ISourceBlock<TOutput>)

Recebe de forma síncrona um valor de uma origem especificada.
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)

Recebe de forma síncrona um valor de uma origem especificada, observando um período de tempo limite opcional.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)

Recebe de forma síncrona um valor de uma fonte especificada, fornecendo um token para cancelar a operação e observando um intervalo de tempo limite opcional.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)

Recebe assincronamente um valor de uma origem especificada.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)

Recebe assincronamente um valor de uma origem especificada e fornece um token para cancelar a operação.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)

Recebe assincronamente um valor de uma origem especificada, observando um período de tempo limite opcional.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)

Recebe assincronamente um valor de uma fonte especificada, fornecendo um token para cancelar a operação e observando um intervalo de tempo limite opcional.

Aplica-se a