IReceivableSourceBlock<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.4.24266.19

Představuje blok toku dat, který podporuje příjem zpráv bez propojení.

generic <typename TOutput>
public interface class IReceivableSourceBlock : System::Threading::Tasks::Dataflow::ISourceBlock<TOutput>

public interface IReceivableSourceBlock<TOutput> : System.Threading.Tasks.Dataflow.ISourceBlock<TOutput>

type IReceivableSourceBlock<'Output> = interface
    interface ISourceBlock<'Output>
    interface IDataflowBlock

Public Interface IReceivableSourceBlock(Of TOutput)
Implements ISourceBlock(Of TOutput)

Parametry typu

TOutput

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

Odvozené

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

System.Threading.Tasks.Dataflow.BatchedJoinBlock<T1,T2>

System.Threading.Tasks.Dataflow.BatchedJoinBlock<T1,T2,T3>

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

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

System.Threading.Tasks.Dataflow.JoinBlock<T1,T2>

System.Threading.Tasks.Dataflow.JoinBlock<T1,T2,T3>

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

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

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

Implementuje

IDataflowBlock ISourceBlock<TOutput>

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>)
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>)
TryReceive(Predicate<TOutput>, TOutput)	Pokusí se synchronně přijmout dostupnou výstupní položku z objektu IReceivableSourceBlock<TOutput>.
TryReceiveAll(IList<TOutput>)	Pokusí se synchronně přijmout všechny dostupné položky z .IReceivableSourceBlock<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> 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.
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.
ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)	Vytvoří objekt IAsyncEnumerable<T> , který umožňuje příjem všech dat ze zdroje.
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.
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)	Pokusí se synchronně přijmout položku z objektu ISourceBlock<TOutput>.