DataflowBlock Classe
Definição
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 conjunto de métodos estáticos (compartilhado no Visual Basic) para trabalhar com blocos de fluxo de dados.
public ref class DataflowBlock abstract sealedpublic static class DataflowBlocktype DataflowBlock = classPublic Module DataflowBlock- Herança
-
DataflowBlock
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.
Métodos
| AsObservable<TOutput>(ISourceBlock<TOutput>) |
Cria uma nova abstração IObservable<T> em relação a ISourceBlock<TOutput>. |
| AsObserver<TInput>(ITargetBlock<TInput>) |
Cria uma nova abstração IObserver<T> em relação a ITargetBlock<TInput>. |
| Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>) |
Monitora as três fontes de fluxo de dados, invocando o manipulador fornecido para a fonte que disponibilizar os dados primeiro. |
| Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>, DataflowBlockOptions) |
Monitora as três fontes de fluxo de dados, invocando o manipulador fornecido para a fonte que disponibilizar os dados primeiro. |
| Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>) |
Monitora duas fontes de fluxo de dados, invocando o manipulador fornecido para a fonte que disponibilizar os dados primeiro. |
| Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, DataflowBlockOptions) |
Monitora duas fontes de fluxo de dados, invocando o manipulador fornecido para a fonte que disponibilizar os dados primeiro. |
| Encapsulate<TInput,TOutput>(ITargetBlock<TInput>, ISourceBlock<TOutput>) |
Encapsula um destino e uma origem em um único propagador. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>) |
Vincula o ISourceBlock<TOutput> ao ITargetBlock<TInput> especificado. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>) |
Vincula o ISourceBlock<TOutput> para o ITargetBlock<TInput> especificado usando o filtro indicado. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>) |
Vincula o ISourceBlock<TOutput> ao ITargetBlock<TInput> especificado usando o filtro indicado. |
| NullTarget<TInput>() |
Obtém um bloco de destino que aceita de forma síncrona todas as mensagens oferecidas a ele e os solta. |
| 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 fonte de saída disponível. |
| Post<TInput>(ITargetBlock<TInput>, TInput) |
Adiciona um item ao ITargetBlock<TInput>. |
| 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. |
| ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken) |
Cria um IAsyncEnumerable<T> que permite o recebimento de todos os dados da origem. |
| 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. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput) |
Oferece assincronamente uma mensagem para o bloco de mensagens de destino, permitindo adiamento. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken) |
Oferece assincronamente uma mensagem para o bloco de mensagens de destino, permitindo adiamento. |
| TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput) |
Tentativas de receber assincronamente um item do ISourceBlock<TOutput>. |