IReceivableSourceBlock<TOutput> Antarmuka

Definisi

Ruang nama:

System.Threading.Tasks.Dataflow

Rakitan:

System.Threading.Tasks.Dataflow.dll

Paket:

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

Mewakili blok aliran data yang mendukung penerimaan pesan tanpa menautkan.

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)

Jenis parameter

TOutput

Menentukan jenis data yang disediakan oleh IReceivableSourceBlock<TOutput>.

Turunan

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>

Penerapan

IDataflowBlock ISourceBlock<TOutput>

Keterangan

Catatan

Pustaka Aliran Data TPL (namespace layanan System.Threading.Tasks.Dataflow) tidak didistribusikan dengan .NET. Untuk menginstal namespace layanan System.Threading.Tasks.Dataflow di Visual Studio, buka proyek, pilih Kelola Paket NuGet dari menu Proyek, dan cari paket System.Threading.Tasks.Dataflow secara online. Atau, untuk menginstalnya menggunakan .NET Core CLI, jalankan dotnet add package System.Threading.Tasks.Dataflow.

Properti

Completion

Task Mendapatkan yang mewakili operasi asinkron dan penyelesaian blok aliran data. (Diperoleh dari IDataflowBlock)

Metode

Complete()	Sinyal kepada IDataflowBlock yang seharusnya tidak diterima atau menghasilkan pesan lagi atau mengkonsumsi pesan yang ditunda lagi. (Diperoleh dari IDataflowBlock)
ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)	Dipanggil oleh yang ditautkan ITargetBlock<TInput> untuk menerima dan menggunakan yang DataflowMessageHeader sebelumnya ditawarkan oleh ini ISourceBlock<TOutput>. (Diperoleh dari ISourceBlock<TOutput>)
Fault(Exception)	IDataflowBlock Menyebabkan selesai dalam keadaanFaulted. (Diperoleh dari IDataflowBlock)
LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)	Menautkan ISourceBlock<TOutput> ke yang ditentukan ITargetBlock<TInput>. (Diperoleh dari ISourceBlock<TOutput>)
ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)	Dipanggil oleh yang ditautkan ITargetBlock<TInput> untuk merilis yang sebelumnya dicadangkan DataflowMessageHeader oleh ini ISourceBlock<TOutput>. (Diperoleh dari ISourceBlock<TOutput>)
ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)	Dipanggil oleh yang ditautkan ITargetBlock<TInput> untuk memesan yang sebelumnya ditawarkan DataflowMessageHeader oleh ini ISourceBlock<TOutput>. (Diperoleh dari ISourceBlock<TOutput>)
TryReceive(Predicate<TOutput>, TOutput)	Mencoba untuk secara sinkron menerima item output yang tersedia dari IReceivableSourceBlock<TOutput>.
TryReceiveAll(IList<TOutput>)	Mencoba untuk secara sinkron menerima semua item yang IReceivableSourceBlock<TOutput>tersedia dari .

Metode Ekstensi

AsObservable<TOutput>(ISourceBlock<TOutput>)	Membuat abstraksi baru IObservable<T> melalui ISourceBlock<TOutput>.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	Menautkan ISourceBlock<TOutput> ke yang ditentukan ITargetBlock<TInput>.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)	Menautkan ISourceBlock<TOutput> ke yang ditentukan ITargetBlock<TInput> menggunakan filter yang ditentukan.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)	Menautkan ISourceBlock<TOutput> ke yang ditentukan ITargetBlock<TInput> menggunakan filter yang ditentukan.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	Menyediakan yang secara asinkron memantau sumber untuk output yang Task<TResult> tersedia.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Menyediakan yang secara asinkron memantau sumber untuk output yang Task<TResult> tersedia.
Receive<TOutput>(ISourceBlock<TOutput>)	Secara sinkron menerima nilai dari sumber tertentu.
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Secara sinkron menerima nilai dari sumber tertentu dan menyediakan token untuk membatalkan operasi.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Secara sinkron menerima nilai dari sumber tertentu, mengamati periode waktu habis opsional.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Secara sinkron menerima nilai dari sumber tertentu, menyediakan token untuk membatalkan operasi dan mengamati interval waktu habis opsional.
ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)	Membuat yang IAsyncEnumerable<T> memungkinkan penerimaan semua data dari sumbernya.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	Secara asinkron menerima nilai dari sumber tertentu.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Secara asinkron menerima nilai dari sumber tertentu dan menyediakan token untuk membatalkan operasi.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Secara asinkron menerima nilai dari sumber tertentu, mengamati periode waktu habis opsional.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Secara asinkron menerima nilai dari sumber tertentu, menyediakan token untuk membatalkan operasi dan mengamati interval waktu habis opsional.
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)	Mencoba untuk menerima item secara sinkron dari ISourceBlock<TOutput>.