Sdílet prostřednictvím


ISourceBlock<TOutput> Rozhraní

Definice

Představuje blok toku dat, který je zdrojem dat.

generic <typename TOutput>
public interface class ISourceBlock : System::Threading::Tasks::Dataflow::IDataflowBlock
public interface ISourceBlock<out TOutput> : System.Threading.Tasks.Dataflow.IDataflowBlock
type ISourceBlock<'Output> = interface
    interface IDataflowBlock
Public Interface ISourceBlock(Of Out TOutput)
Implements IDataflowBlock

Parametry typu

TOutput

Určuje typ dat, která ISourceBlock<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>

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 .

ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)

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

ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)

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

Metody rozšíření

AsObservable<TOutput>(ISourceBlock<TOutput>)

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

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.

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.

Platí pro