DataflowBlock Classe
Definição
Importante
Algumas informações dizem respeito a um produto pré-lançado que pode ser substancialmente modificado antes de ser lançado. A Microsoft não faz garantias, de forma expressa ou implícita, em relação à informação aqui apresentada.
Fornece um conjunto de métodos estáticos (Partilhados 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
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.
Métodos
| Name | 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) |
Monitoriza três fontes de fluxo de dados, invocando o handler fornecido para a fonte que disponibiliza os dados primeiro. |
| Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>) |
Monitoriza três fontes de fluxo de dados, invocando o handler fornecido para a fonte que disponibiliza os dados primeiro. |
| Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, DataflowBlockOptions) |
Monitoriza duas fontes de fluxo de dados, invocando o manipulador fornecido para a fonte que disponibiliza os dados primeiro. |
| Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>) |
Monitoriza duas fontes de fluxo de dados, invocando o manipulador fornecido para a fonte que disponibiliza os dados primeiro. |
| Encapsulate<TInput,TOutput>(ITargetBlock<TInput>, ISourceBlock<TOutput>) |
Encapsula um alvo e uma fonte num único propagador. |
| 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>. |
| NullTarget<TInput>() |
Recebe um bloco-alvo que aceita sincronizadamente todas as mensagens oferecidas e as descarta. |
| 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. |
| Post<TInput>(ITargetBlock<TInput>, TInput) |
Publica um item no ITargetBlock<TInput>arquivo . |
| 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. |
| ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken) |
Cria um IAsyncEnumerable<T> que permite receber todos os dados da fonte. |
| 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. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken) |
Assíncrono, oferece uma mensagem ao bloco de mensagens alvo, permitindo adiamento. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput) |
Assíncrono, oferece uma mensagem ao bloco de mensagens alvo, permitindo adiamento. |
| TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput) |
Tentativas de receber síncronicamente um item do ISourceBlock<TOutput>. |
