IPropagatorBlock<TInput,TOutput> Rozhraní

Definice

Obor názvů:

System.Threading.Tasks.Dataflow

Sestavení:

System.Threading.Tasks.Dataflow.dll

Balíček:

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

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>

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é

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>

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í toku dat bloku. (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> zadaný ITargetBlock<TInput>parametr . (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> zadaný ITargetBlock<TInput>parametr .
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 z zadaného zdroje, poskytuje token pro zrušení operace a sleduje volitelný interval časového limitu.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	Asynchronně přijímá 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í.