DataflowBlock Kelas

Definisi

Ruang nama:

System.Threading.Tasks.Dataflow

Rakitan:

System.Threading.Tasks.Dataflow.dll

Paket:

System.Threading.Tasks.Dataflow v11.0.0-preview.7.26381.103

Sumber:

DataflowBlock.cs

Menyediakan sekumpulan metode statis (Dibagikan dalam Visual Basic) untuk bekerja dengan blok aliran data.

public ref class DataflowBlock abstract sealed

public static class DataflowBlock

type DataflowBlock = class

Public Module DataflowBlock

Warisan

Object

DataflowBlock

Keterangan

Note

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

Metode

Nama	Deskripsi
AsObservable<TOutput>(ISourceBlock<TOutput>)	Membuat abstraksi baru IObservable<T> melalui ISourceBlock<TOutput>.
AsObserver<TInput>(ITargetBlock<TInput>)	Membuat abstraksi baru IObserver<T> melalui ITargetBlock<TInput>.
Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>, DataflowBlockOptions)	Memantau tiga sumber aliran data, memanggil handler yang disediakan untuk sumber mana pun yang menyediakan data terlebih dahulu.
Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>)	Memantau tiga sumber aliran data, memanggil handler yang disediakan untuk sumber mana pun yang menyediakan data terlebih dahulu.
Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, DataflowBlockOptions)	Memantau dua sumber aliran data, memanggil handler yang disediakan untuk sumber mana pun yang menyediakan data terlebih dahulu.
Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>)	Memantau dua sumber aliran data, memanggil handler yang disediakan untuk sumber mana pun yang menyediakan data terlebih dahulu.
Encapsulate<TInput,TOutput>(ITargetBlock<TInput>, ISourceBlock<TOutput>)	Merangkum target dan sumber ke dalam satu penyebar.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)	Menautkan ISourceBlock<TOutput> ke yang ditentukan ITargetBlock<TInput> menggunakan filter yang ditentukan.
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>)	Menautkan ISourceBlock<TOutput> ke ITargetBlock<TInput>.
NullTarget<TInput>()	Mendapatkan blok target yang secara sinkron menerima semua pesan yang ditawarkan kepadanya dan menghilangkannya.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Menyediakan yang secara asinkron memantau sumber untuk output yang Task<TResult> tersedia.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	Menyediakan yang secara asinkron memantau sumber untuk output yang Task<TResult> tersedia.
Post<TInput>(ITargetBlock<TInput>, TInput)	Memposting item ke ITargetBlock<TInput>.
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Secara sinkron menerima nilai dari sumber tertentu dan menyediakan token untuk membatalkan operasi.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Secara sinkron menerima nilai dari sumber tertentu, menyediakan token untuk membatalkan operasi dan mengamati interval batas waktu opsional.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Secara sinkron menerima nilai dari sumber tertentu, mengamati periode waktu habis opsional.
Receive<TOutput>(ISourceBlock<TOutput>)	Secara sinkron menerima nilai dari sumber tertentu.
ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)	Membuat yang IAsyncEnumerable<T> memungkinkan penerimaan semua data dari sumber.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Secara asinkron menerima nilai dari sumber tertentu dan menyediakan token untuk membatalkan operasi.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Secara asinkron menerima nilai dari sumber tertentu, menyediakan token untuk membatalkan operasi dan mengamati interval waktu habis opsional.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Secara asinkron menerima nilai dari sumber tertentu, mengamati periode waktu habis opsional.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	Secara asinkron menerima nilai dari sumber tertentu.
SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken)	Secara asinkron menawarkan pesan ke blok pesan target, memungkinkan penundaan.
SendAsync<TInput>(ITargetBlock<TInput>, TInput)	Secara asinkron menawarkan pesan ke blok pesan target, memungkinkan penundaan.
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)	Mencoba untuk menerima item secara sinkron dari ISourceBlock<TOutput>.