DataflowBlock Sınıf

Tanım

Ad Alanı:

System.Threading.Tasks.Dataflow

Bütünleştirilmiş Kod:

System.Threading.Tasks.Dataflow.dll

Veri akışı bloklarıyla çalışmak için bir dizi statik (Visual Basic paylaşılan) yöntem sağlar.

public ref class DataflowBlock abstract sealed

public static class DataflowBlock

type DataflowBlock = class

Public Module DataflowBlock

Devralma

Object

DataflowBlock

Açıklamalar

Not

TPL veri akışı kitaplığı ( System.Threading.Tasks.Dataflow ad alanı) .NET ile dağıtılmaz. System.Threading.Tasks.DataflowVisual Studio 'da ad alanını yüklemek için projenizi açın, Proje menüsünden NuGet Paketlerini Yönet ' i seçin ve paketi çevrimiçi olarak arayın System.Threading.Tasks.Dataflow . Alternatif olarak, .NET Core CLIkullanarak yüklemek için öğesini çalıştırın dotnet add package System.Threading.Tasks.Dataflow .

Yöntemler

AsObservable<TOutput>(ISourceBlock<TOutput>)	üzerinde ISourceBlock<TOutput>yeni IObservable<T> bir soyutlama oluşturur.
AsObserver<TInput>(ITargetBlock<TInput>)	üzerinde ITargetBlock<TInput>yeni IObserver<T> bir soyutlama oluşturur.
Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>)	Sağlanan işleyiciyi ilk olarak kullanılabilir hale getiren kaynak için sağlanan işleyiciyi çağırarak üç veri akışı kaynağını izler.
Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>, DataflowBlockOptions)	Sağlanan işleyiciyi ilk olarak kullanılabilir hale getiren kaynak için sağlanan işleyiciyi çağırarak üç veri akışı kaynağını izler.
Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>)	İki veri akışı kaynağını izler ve sağlanan işleyiciyi hangi kaynak için önce kullanılabilir hale getirirse çağırarak izler.
Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, DataflowBlockOptions)	İki veri akışı kaynağını izler ve sağlanan işleyiciyi hangi kaynak için önce kullanılabilir hale getirirse çağırarak izler.
Encapsulate<TInput,TOutput>(ITargetBlock<TInput>, ISourceBlock<TOutput>)	Hedefi ve kaynağı tek bir yayıcıya kapsüller.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	öğesini ISourceBlock<TOutput> belirtilen ITargetBlock<TInput>öğesine bağlar.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)	ISourceBlock<TOutput> belirtilen filtreyi kullanarak öğesini belirtilene ITargetBlock<TInput> bağlar.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)	ISourceBlock<TOutput> belirtilen filtreyi kullanarak öğesini belirtilene ITargetBlock<TInput> bağlar.
NullTarget<TInput>()	Sunulan tüm iletileri zaman uyumlu olarak kabul eden ve bunları düşüren bir hedef bloğu alır.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	Kaynağı kullanılabilir çıkış için zaman uyumsuz olarak izleyen bir Task<TResult> sağlar.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Kaynağı kullanılabilir çıkış için zaman uyumsuz olarak izleyen bir Task<TResult> sağlar.
Post<TInput>(ITargetBlock<TInput>, TInput)	Öğesine bir öğe postalar ITargetBlock<TInput>.
Receive<TOutput>(ISourceBlock<TOutput>)	Belirtilen kaynaktan zaman uyumlu olarak bir değer alır.
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Belirtilen kaynaktan zaman uyumlu olarak bir değer alır ve işlemi iptal etmek için bir belirteç sağlar.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Belirli bir kaynaktan isteğe bağlı bir zaman aşımı süresini gözlemleyerek zaman uyumlu olarak bir değer alır.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Belirtilen kaynaktan zaman uyumlu olarak bir değer alır ve işlemi iptal etmek için bir belirteç sağlar ve isteğe bağlı bir zaman aşımı aralığını gözlemler.
ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)	Kaynaktan tüm verilerin alınmasını sağlayan bir IAsyncEnumerable<T> oluşturur.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	Belirtilen kaynaktan zaman uyumsuz olarak bir değer alır.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Belirli bir kaynaktan zaman uyumsuz olarak bir değer alır ve işlemi iptal etmek için bir belirteç sağlar.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Belirli bir kaynaktan zaman uyumsuz olarak bir değer alır ve isteğe bağlı bir zaman aşımı süresini gözlemler.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Belirtilen kaynaktan zaman uyumsuz olarak bir değer alır ve işlemi iptal etmek için bir belirteç sağlar ve isteğe bağlı bir zaman aşımı aralığını gözlemler.
SendAsync<TInput>(ITargetBlock<TInput>, TInput)	Zaman uyumsuz olarak hedef ileti bloğuna bir ileti seçerek ertelemeye olanak tanır.
SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken)	Zaman uyumsuz olarak hedef ileti bloğuna bir ileti seçerek ertelemeye olanak tanır.
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)	öğesinden ISourceBlock<TOutput>bir öğeyi zaman uyumlu olarak almaya çalışır.