ISourceBlock<TOutput> Antarmuka

Referensi

Definisi

Ruang nama:: System.Threading.Tasks.Dataflow

Rakitan:: System.Threading.Tasks.Dataflow.dll

Paket:: System.Threading.Tasks.Dataflow v8.0.0

Paket:: System.Threading.Tasks.Dataflow v9.0.0-preview.4.24266.19

Penting

Beberapa informasi terkait produk prarilis yang dapat diubah secara signifikan sebelum dirilis. Microsoft tidak memberikan jaminan, tersirat maupun tersurat, sehubungan dengan informasi yang diberikan di sini.

Mewakili blok aliran data yang merupakan sumber data.

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

Jenis parameter

TOutput

Menentukan jenis data yang disediakan oleh ISourceBlock<TOutput>.

Parameter jenis ini bersifat kovarian. Artinya, Anda bisa menggunakan jenis yang Anda tentukan atau jenis apa pun yang lebih banyak diturunkan. Untuk informasi lebih lanjut tentang kovariansi dan kontravariansi, lihat Kovariansi dan Kontravariansi dalam Generik.

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>

Lainnya…

Penerapan: IDataflowBlock

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 untuk 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 ditawarkan sebelumnya oleh ini ISourceBlock<TOutput>.
Fault(Exception)	IDataflowBlock Menyebabkan selesai dalam keadaanFaulted. (Diperoleh dari IDataflowBlock)
LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)	Menautkan ke ISourceBlock<TOutput> yang ditentukan ITargetBlock<TInput>.
ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)	Dipanggil oleh yang ditautkan ITargetBlock<TInput> untuk merilis yang sebelumnya dicadangkan DataflowMessageHeader oleh ini ISourceBlock<TOutput>.
ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)	Dipanggil oleh yang ditautkan ITargetBlock<TInput> untuk memesan yang sebelumnya ditawarkan DataflowMessageHeader oleh ini ISourceBlock<TOutput>.

Metode Ekstensi

AsObservable<TOutput>(ISourceBlock<TOutput>)	Membuat abstraksi baru IObservable<T> melalui ISourceBlock<TOutput>.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	Menautkan ke ISourceBlock<TOutput> 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.
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.

Berlaku untuk

Bagikan melalui