Sdílet prostřednictvím


IPropagatorBlock<TInput,TOutput> Rozhraní

Definice

Představuje blok toku dat, který je jak cílem dat, tak zdrojem dat.

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

Určuje typ dat akceptovaných nástrojem IPropagatorBlock<TInput,TOutput>.

Tento parametr typu je kontravariantní. To znamená, že můžete použít buď zadaný typ, nebo libovolný typ, který je méně odvozený. Další informace o kovarianci a kontravarianci najdete v tématu popisujícím kovarianci a kontravarianci u parametrického polymorfismu.
TOutput

Určuje typ dat, která IPropagatorBlock<TInput,TOutput>poskytuje .

Tento parametr typu je kovariantní. To znamená, že můžete použít buď zadaný typ, nebo libovolný typ, který je více odvozený. Další informace o kovarianci a kontravarianci najdete v tématu popisujícím kovarianci a kontravarianci u parametrického polymorfismu.
Odvozené
Implementuje

Poznámky

Poznámka

Knihovna toků dat TPL (obor názvů) se s .NET nedistribuuje System.Threading.Tasks.Dataflow . Pokud chcete nainstalovat System.Threading.Tasks.Dataflow obor názvů v sadě Visual Studio, otevřete projekt, v nabídce Projekt zvolte Spravovat balíčky NuGet a vyhledejte System.Threading.Tasks.Dataflow balíček online. Pokud ho chcete nainstalovat pomocí rozhraní příkazového řádku .NET Core, spusťte příkaz dotnet add package System.Threading.Tasks.Dataflow.

Vlastnosti

Completion

Získá, Task který představuje asynchronní operaci a dokončení bloku toku dat.

(Zděděno od IDataflowBlock)

Metody

Complete()

Signalizuje, IDataflowBlock že by neměl přijímat, vytvářet žádné další zprávy ani využívat další odložené zprávy.

(Zděděno od IDataflowBlock)
ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)

Volá se propojeným ITargetBlock<TInput> uživatelem k přijetí a využití DataflowMessageHeader dříve nabízeného .ISourceBlock<TOutput>

(Zděděno od ISourceBlock<TOutput>)
Fault(Exception)

Způsobí, že IDataflowBlock se dokončí ve Faulted stavu .

(Zděděno od IDataflowBlock)
LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)

Prodá ISourceBlock<TOutput> zadanou ITargetBlock<TInput>hodnotu .

(Zděděno od ISourceBlock<TOutput>)
OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, Boolean)

Nabídne zprávu pro ITargetBlock<TInput>, která cílovému cíli umožní zprávu spotřebovat nebo odložit.

(Zděděno od ITargetBlock<TInput>)
ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)

Volána propojeným ITargetBlock<TInput> pro vydání dříve rezervované DataflowMessageHeader tímto ISourceBlock<TOutput>.

(Zděděno od ISourceBlock<TOutput>)
ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)

Volá se propojeným ITargetBlock<TInput> uživatelem, aby si rezervoval dříve nabízený DataflowMessageHeaderISourceBlock<TOutput>.

(Zděděno od ISourceBlock<TOutput>)

Metody rozšíření

AsObservable<TOutput>(ISourceBlock<TOutput>)

Vytvoří novou IObservable<T> abstrakci pro ISourceBlock<TOutput>.

AsObserver<TInput>(ITargetBlock<TInput>)

Vytvoří novou IObserver<T> abstrakci pro ITargetBlock<TInput>.

LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)

Prodá ISourceBlock<TOutput> zadanou ITargetBlock<TInput>hodnotu .

LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)

Odkazuje na ISourceBlock<TOutput> zadaný ITargetBlock<TInput> pomocí zadaného filtru.

LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)

Odkazuje na ISourceBlock<TOutput> zadaný ITargetBlock<TInput> pomocí zadaného filtru.

OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)

Poskytuje, Task<TResult> že asynchronně monitoruje zdroj pro dostupný výstup.

OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)

Poskytuje, Task<TResult> že asynchronně monitoruje zdroj pro dostupný výstup.

Post<TInput>(ITargetBlock<TInput>, TInput)

Publikuje položku do .ITargetBlock<TInput>

Receive<TOutput>(ISourceBlock<TOutput>)

Synchronně přijímá hodnotu ze zadaného zdroje.

Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)

Synchronně přijímá hodnotu ze zadaného zdroje a poskytuje token pro zrušení operace.

Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)

Synchronně přijímá hodnotu z zadaného zdroje a sleduje volitelné období časového limitu.

Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)

Synchronně přijímá hodnotu ze zadaného zdroje, poskytuje token pro zrušení operace a sleduje volitelný interval časového limitu.

ReceiveAsync<TOutput>(ISourceBlock<TOutput>)

Asynchronně obdrží hodnotu ze zadaného zdroje.

ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)

Asynchronně přijímá hodnotu ze zadaného zdroje a poskytuje token pro zrušení operace.

ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)

Asynchronně přijímá hodnotu ze zadaného zdroje a sleduje volitelné období časového limitu.

ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)

Asynchronně přijímá hodnotu ze zadaného zdroje, poskytuje token pro zrušení operace a sleduje volitelný interval časového limitu.

SendAsync<TInput>(ITargetBlock<TInput>, TInput)

Asynchronně nabídne zprávu cílovému bloku zpráv, což umožňuje odložení.

SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken)

Asynchronně nabídne zprávu cílovému bloku zpráv, což umožňuje odložení.

Platí pro