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 (compartilhados em 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
Note
A Biblioteca de Fluxo de Dados TPL (o namespace System.Threading.Tasks.Dataflow) não é distribuída com .NET. Para instalar o namespace System.Threading.Tasks.Dataflow no Visual Studio, abra seu projeto, escolha Gerenciar Pacotes NuGet no menu do 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
| Nome | 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>. |
| Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>, DataflowBlockOptions) |
Monitora três fontes de fluxo de dados, invocando o manipulador fornecido para qualquer fonte que disponibilize os dados primeiro. |
| Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>) |
Monitora três fontes de fluxo de dados, invocando o manipulador fornecido para qualquer fonte que disponibilize 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 qualquer fonte que disponibilize 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 qualquer fonte que disponibilize 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>, DataflowLinkOptions, Predicate<TOutput>) |
Vincula o ISourceBlock<TOutput> arquivo ao especificado ITargetBlock<TInput> usando o filtro especificado. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>) |
Vincula o ISourceBlock<TOutput> arquivo ao especificado ITargetBlock<TInput> usando o filtro especificado. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>) |
Vincula o ISourceBlock<TOutput> link para o especificado ITargetBlock<TInput>. |
| NullTarget<TInput>() |
Obtém um bloco de destino que aceita de forma síncrona todas as mensagens oferecidas a ele e as descarta. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Fornece um Task<TResult> que monitora assíncronamente a origem da saída disponível. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>) |
Fornece um Task<TResult> que monitora assíncronamente a origem da saída disponível. |
| Post<TInput>(ITargetBlock<TInput>, TInput) |
Posta um item no ITargetBlock<TInput>. |
| 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, CancellationToken) |
Recebe de forma síncrona um valor de uma origem especificada, fornecendo um token para cancelar a operação e observando um intervalo de tempo limite opcional. |
| 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>) |
Recebe de forma síncrona um valor de uma origem especificada. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Recebe de forma assíncrona um valor de uma origem especificada e fornece um token para cancelar a operação. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Recebe de forma assíncrona um valor de uma origem especificada, fornecendo um token para cancelar a operação e observando um intervalo de tempo limite opcional. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Recebe de forma assíncrona um valor de uma origem especificada, observando um período de tempo limite opcional. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>) |
Recebe de forma assíncrona um valor de uma origem especificada. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken) |
Oferece de forma assíncrona uma mensagem para o bloco de mensagens de destino, permitindo o adiamento. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput) |
Oferece de forma assíncrona uma mensagem para o bloco de mensagens de destino, permitindo o adiamento. |
| TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput) |
Tenta receber um item de forma síncrona do ISourceBlock<TOutput>. |