IPropagatorBlock<TInput,TOutput> Interfejs

Definicja

Przestrzeń nazw:

System.Threading.Tasks.Dataflow

Zestaw:

System.Threading.Tasks.Dataflow.dll

Pakiet:

System.Threading.Tasks.Dataflow v9.0.0-preview.5.24306.7

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>

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

System.Threading.Tasks.Dataflow.BatchBlock<T>

System.Threading.Tasks.Dataflow.BroadcastBlock<T>

System.Threading.Tasks.Dataflow.BufferBlock<T>

System.Threading.Tasks.Dataflow.TransformBlock<TInput,TOutput>

System.Threading.Tasks.Dataflow.TransformManyBlock<TInput,TOutput>

System.Threading.Tasks.Dataflow.WriteOnceBlock<T>

Implementuje

IDataflowBlock ISourceBlock<TOutput> ITargetBlock<TInput>

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

Complete()	Sygnały do IDataflowBlock tego, że nie powinny akceptować ani tworzyć więcej komunikatów, ani nie zużywać żadnych bardziej odroczonych komunikatów. (Odziedziczone po IDataflowBlock)
ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)	Wywołana przez link ITargetBlock<TInput> do akceptowania i korzystania z wcześniej oferowanej przez tę ISourceBlock<TOutput>usługę DataflowMessageHeader . (Odziedziczone po ISourceBlock<TOutput>)
Fault(Exception)	IDataflowBlock Powoduje ukończenie Faulted operacji w stanie. (Odziedziczone po IDataflowBlock)
LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)	Łączy element ISourceBlock<TOutput> z określonym ITargetBlock<TInput>elementem . (Odziedziczone po ISourceBlock<TOutput>)
OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, Boolean)	Oferuje komunikat do ITargetBlock<TInput>obiektu , dając docelową możliwość korzystania lub odroczenia wiadomości. (Odziedziczone po ITargetBlock<TInput>)
ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)	Wywoływana przez połączony ITargetBlock<TInput> element z wydaniem wcześniej zastrzeżonym DataflowMessageHeader przez ten ISourceBlock<TOutput>element . (Odziedziczone po ISourceBlock<TOutput>)
ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)	Wywoływana przez połączonego ITargetBlock<TInput> z rezerwą wcześniej oferowaną DataflowMessageHeader przez tę ISourceBlock<TOutput>usługę . (Odziedziczone po ISourceBlock<TOutput>)

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.