IReceivableSourceBlock<TOutput> Rozhraní

Definice

Obor názvů:

System.Threading.Tasks.Dataflow

Sestavení:

System.Threading.Tasks.Dataflow.dll

Balíček:

System.Threading.Tasks.Dataflow v11.0.0-rc.1.26425.128

Zdroj:

IReceivableSourceBlock.cs

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 zadaných parametrem IReceivableSourceBlock<TOutput>.

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>

Vlastnosti

Name	Description
Completion	Task Získá, který představuje asynchronní operace a dokončení bloku toku dat. (Zděděno od IDataflowBlock)

Metody

Name	Description
Complete()	Signály pro IDataflowBlock to, že by neměl přijímat ani vytvářet žádné další zprávy, ani využívat žádné odložené zprávy. (Zděděno od IDataflowBlock)
ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)	Volal odkaz ITargetBlock<TInput> , aby přijímal a spotřebovával DataflowMessageHeader dříve nabízené tímto ISourceBlock<TOutput>. (Zděděno od ISourceBlock<TOutput>)
Fault(Exception)	Způsobí, že se IDataflowBlock dokončí ve Faulted stavu. (Zděděno od IDataflowBlock)
LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)	Odkazuje na ISourceBlock<TOutput> zadanou ITargetBlock<TInput>. (Zděděno od ISourceBlock<TOutput>)
ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)	Volal by odkaz ITargetBlock<TInput> na vydání dříve rezervované DataflowMessageHeader tímto ISourceBlock<TOutput>. (Zděděno od ISourceBlock<TOutput>)
ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)	Volal by odkaz ITargetBlock<TInput> na rezervaci dříve nabízené DataflowMessageHeader tímto ISourceBlock<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 objektu IReceivableSourceBlock<TOutput>.

Metody rozšíření

Name	Description
AsObservable<TOutput>(ISourceBlock<TOutput>)	Vytvoří novou IObservable<T> abstrakci přes ISourceBlock<TOutput>.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)	Pro propojení se ISourceBlock<TOutput> zadaným ITargetBlock<TInput> filtrem.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)	Pro propojení se ISourceBlock<TOutput> zadaným ITargetBlock<TInput> filtrem.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	Odkazuje na ISourceBlock<TOutput> zadanou ITargetBlock<TInput>.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Task<TResult> Poskytuje, že asynchronně monitoruje zdroj pro dostupný výstup.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	Task<TResult> Poskytuje, že asynchronně monitoruje zdroj pro dostupný výstup.
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, CancellationToken)	Synchronně přijímá hodnotu ze zadaného zdroje a poskytuje token pro zrušení operace a sledování volitelného intervalu časového limitu.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Synchronně přijímá hodnotu ze zadaného zdroje a sleduje volitelnou dobu vypršení časového limitu.
Receive<TOutput>(ISourceBlock<TOutput>)	Synchronně přijímá hodnotu ze zadaného zdroje.
ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)	Vytvoří objekt IAsyncEnumerable<T> , který umožňuje přijímat všechna data ze 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, CancellationToken)	Asynchronně přijímá hodnotu ze zadaného zdroje a poskytuje token pro zrušení operace a sledování volitelného intervalu časového limitu.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Asynchronně přijímá hodnotu ze zadaného zdroje a sleduje volitelnou dobu vypršení časového limitu.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	Asynchronně přijímá hodnotu ze zadaného zdroje.
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)	Pokusí se synchronně přijmout položku z objektu ISourceBlock<TOutput>.