DataflowBlock Klasa
Definicja
Ważne
Niektóre informacje odnoszą się do produktu w wersji wstępnej, który może zostać znacząco zmodyfikowany przed wydaniem. Firma Microsoft nie udziela żadnych gwarancji, jawnych lub domniemanych, w odniesieniu do informacji podanych w tym miejscu.
Udostępnia zestaw statycznych metod (udostępnionych w Visual Basic) do pracy z blokami przepływu danych.
public ref class DataflowBlock abstract sealedpublic static class DataflowBlocktype DataflowBlock = classPublic Module DataflowBlock- Dziedziczenie
-
DataflowBlock
Uwagi
Uwaga
Biblioteka przepływu danych TPL ( System.Threading.Tasks.Dataflow przestrzeń nazw) nie jest dystrybuowana z platformą .NET. Aby zainstalować System.Threading.Tasks.Dataflow przestrzeń nazw w programie Visual Studio, Otwórz projekt, wybierz pozycję Zarządzaj pakietami NuGet z menu projekt i Wyszukaj w trybie online System.Threading.Tasks.Dataflow pakiet. Alternatywnie, aby zainstalować go przy użyciu interfejs wiersza polecenia platformy .NET Core, uruchom polecenie dotnet add package System.Threading.Tasks.Dataflow .
Metody
| AsObservable<TOutput>(ISourceBlock<TOutput>) |
Tworzy nową IObservable<T> abstrakcję dla elementu ISourceBlock<TOutput>. |
| AsObserver<TInput>(ITargetBlock<TInput>) |
Tworzy nową IObserver<T> abstrakcję dla elementu ITargetBlock<TInput>. |
| Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>) |
Monitoruje trzy źródła przepływu danych, wywołując podaną procedurę obsługi dla niezależnie od tego, które źródło udostępnia dane jako pierwsze. |
| Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>, DataflowBlockOptions) |
Monitoruje trzy źródła przepływu danych, wywołując podaną procedurę obsługi dla niezależnie od tego, które źródło udostępnia dane jako pierwsze. |
| Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>) |
Monitoruje dwa źródła przepływu danych, wywołując podaną procedurę obsługi dla niezależnie od tego, które źródło udostępnia dane jako pierwsze. |
| Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, DataflowBlockOptions) |
Monitoruje dwa źródła przepływu danych, wywołując podaną procedurę obsługi dla niezależnie od tego, które źródło udostępnia dane jako pierwsze. |
| Encapsulate<TInput,TOutput>(ITargetBlock<TInput>, ISourceBlock<TOutput>) |
Hermetyzuje element docelowy i źródło w jeden propagator. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>) |
Tworzy łącze ISourceBlock<TOutput> do określonego ITargetBlock<TInput>elementu . |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>) |
Łączy element z ISourceBlock<TOutput> określonym ITargetBlock<TInput> filtrem przy użyciu określonego filtru. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>) |
Łączy element z ISourceBlock<TOutput> określonym ITargetBlock<TInput> filtrem przy użyciu określonego filtru. |
| NullTarget<TInput>() |
Pobiera blok docelowy, który synchronicznie akceptuje wszystkie oferowane mu komunikaty i usuwa je. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>) |
Task<TResult> Zapewnia asynchroniczne monitorowanie źródła pod kątem dostępnych danych wyjściowych. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Task<TResult> Zapewnia asynchroniczne monitorowanie źródła pod kątem dostępnych danych wyjściowych. |
| Post<TInput>(ITargetBlock<TInput>, TInput) |
Publikuje element w elemencie ITargetBlock<TInput>. |
| Receive<TOutput>(ISourceBlock<TOutput>) |
Synchronicznie odbiera wartość z określonego źródła. |
| Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Synchronicznie odbiera wartość z określonego źródła i udostępnia token umożliwiający anulowanie operacji. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Synchronicznie odbiera wartość z określonego źródła, obserwując opcjonalny okres limitu czasu. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Synchronicznie odbiera wartość z określonego źródła, zapewniając token umożliwiający anulowanie operacji i obserwowanie opcjonalnego interwału limitu czasu. |
| ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken) |
Tworzy obiekt IAsyncEnumerable<T> , który umożliwia odbieranie wszystkich danych ze źródła. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>) |
Asynchronicznie odbiera wartość z określonego źródła. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Asynchronicznie odbiera wartość z określonego źródła i udostępnia token umożliwiający anulowanie operacji. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Asynchronicznie odbiera wartość z określonego źródła, obserwując opcjonalny limit czasu. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Asynchronicznie odbiera wartość z określonego źródła, zapewniając token umożliwiający anulowanie operacji i obserwowanie opcjonalnego interwału limitu czasu. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput) |
Asynchronicznie oferuje komunikat do docelowego bloku komunikatów, co pozwala na odroczenie. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken) |
Asynchronicznie oferuje komunikat do docelowego bloku komunikatów, co pozwala na odroczenie. |
| TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput) |
Próbuje synchronicznie odebrać element z elementu ISourceBlock<TOutput>. |