IReceivableSourceBlock<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 suporta receber mensagens sem ligação.

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

Parâmetros de Tipo Genérico

TOutput

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

Derivado
Implementações
IDataflowBlock ISourceBlock<TOutput>

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>)
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>)
TryReceive(Predicate<TOutput>, TOutput)

Tentativas de receber síncronicamente um item de saída disponível do IReceivableSourceBlock<TOutput>.
TryReceiveAll(IList<TOutput>)

Tentativas de receber síncronicamente todos os itens disponíveis do IReceivableSourceBlock<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.
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)

Tentativas de receber síncronicamente um item do ISourceBlock<TOutput>.

Aplica-se a