IPropagatorBlock<TInput,TOutput> Interfejs
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.
Reprezentuje blok przepływu danych, który jest zarówno obiektem docelowym danych, jak i źródłem danych.
generic <typename TInput, typename TOutput>
public interface class IPropagatorBlock : System::Threading::Tasks::Dataflow::ISourceBlock<TOutput>, System::Threading::Tasks::Dataflow::ITargetBlock<TInput>public interface IPropagatorBlock<in TInput,out TOutput> : System.Threading.Tasks.Dataflow.ISourceBlock<out TOutput>, System.Threading.Tasks.Dataflow.ITargetBlock<in TInput>type IPropagatorBlock<'Input, 'Output> = interface
interface ITargetBlock<'Input>
interface IDataflowBlock
interface ISourceBlock<'Output>type IPropagatorBlock<'Input, 'Output> = interface
interface IDataflowBlock
interface ISourceBlock<'Output>
interface ITargetBlock<'Input>Public Interface IPropagatorBlock(Of In TInput, Out TOutput)
Implements ISourceBlock(Of Out TOutput), ITargetBlock(Of In TInput)Parametry typu
- TInput
Określa typ danych akceptowanych przez IPropagatorBlock<TInput,TOutput>element .
Ten parametr typu jest kontrawariantny. Oznacza to, że możesz użyć typu, który został przez Ciebie określony, lub dowolnego typu, który jest mniej pochodny. Aby uzyskać więcej informacji o kowariancji i kontrawariancji, zobacz Kowariancja i kontrawariancja w typach ogólnych.- TOutput
Określa typ danych dostarczonych przez IPropagatorBlock<TInput,TOutput>obiekt .
Ten parametr typu jest kowariantny. Oznacza to, że możesz użyć typu, który został przez Ciebie określony, lub dowolnego typu, który jest bardziej pochodny. Aby uzyskać więcej informacji o kowariancji i kontrawariancji, zobacz Kowariancja i kontrawariancja w typach ogólnych.- Pochodne
- Implementuje
Uwagi
Uwaga
Biblioteka przepływu danych TPL ( System.Threading.Tasks.Dataflow przestrzeń nazw) nie jest dystrybuowana za pomocą platformy .NET. Aby zainstalować System.Threading.Tasks.Dataflow przestrzeń nazw w programie Visual Studio, otwórz projekt, wybierz pozycję Zarządzaj pakietami NuGet z menu Project i wyszukaj pakiet w trybie online System.Threading.Tasks.Dataflow . Alternatywnie, aby zainstalować go przy użyciu interfejsu wiersza polecenia platformy .NET Core, uruchom polecenie dotnet add package System.Threading.Tasks.Dataflow.
Właściwości
| Completion |
Pobiera element reprezentujący operację Task asynchroniczną i ukończenie bloku przepływu danych. (Odziedziczone po IDataflowBlock) |
Metody
Metody rozszerzania
| AsObservable<TOutput>(ISourceBlock<TOutput>) |
Tworzy nową IObservable<T> abstrakcję nad elementem ISourceBlock<TOutput>. |
| AsObserver<TInput>(ITargetBlock<TInput>) |
Tworzy nową IObserver<T> abstrakcję nad elementem ITargetBlock<TInput>. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>) |
Łączy element ISourceBlock<TOutput> z określonym ITargetBlock<TInput>elementem . |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>) |
Łączy element ISourceBlock<TOutput> z określonym ITargetBlock<TInput> filtrem przy użyciu określonego filtru. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>) |
Łączy element ISourceBlock<TOutput> z określonym ITargetBlock<TInput> filtrem przy użyciu określonego filtru. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>) |
Task<TResult> Zapewnia, że asynchronicznie monitoruje źródło dostępnych danych wyjściowych. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Task<TResult> Zapewnia, że asynchronicznie monitoruje źródło 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 do anulowania operacji. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Synchronicznie odbiera wartość z określonego źródła, obserwując opcjonalny okres przekroczenia 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 przekroczenia limitu czasu. |
| 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 do anulowania operacji. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Asynchronicznie odbiera wartość z określonego źródła, obserwując opcjonalny okres przekroczenia limitu 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 przekroczenia 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. |
