DataflowBlock Sınıf

Tanım

Ad Alanı:

System.Threading.Tasks.Dataflow

Bütünleştirilmiş Kod:

System.Threading.Tasks.Dataflow.dll

Paket:

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

Kaynak:

DataflowBlock.cs

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

Note

TPL Veri Akışı Kitaplığı (System.Threading.Tasks.Dataflow ad alanı) .NET ile dağıtılmaz. Visual Studio'da System.Threading.Tasks.Dataflow ad alanını yüklemek için projenizi açın, Project menüsünden NuGet Paketlerini Yönet seçin ve System.Threading.Tasks.Dataflow paketini çevrimiçi olarak arayın. Alternatif olarak, .NET Core CLI kullanarakyüklemek için dotnet add package System.Threading.Tasks.Dataflowçalıştırın.

Yöntemler

Name	Description
AsObservable<TOutput>(ISourceBlock<TOutput>)	üzerinde IObservable<T>yeni ISourceBlock<TOutput> bir soyutlama oluşturur.
AsObserver<TInput>(ITargetBlock<TInput>)	üzerinde IObserver<T>yeni ITargetBlock<TInput> bir soyutlama oluşturur.
Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>, DataflowBlockOptions)	Üç veri akışı kaynağını izler ve sağlanan işleyiciyi hangi kaynak verileri önce kullanılabilir hale getirirse çağırır.
Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>)	Üç veri akışı kaynağını izler ve sağlanan işleyiciyi hangi kaynak verileri önce kullanılabilir hale getirirse çağırır.
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 verileri önce kullanılabilir hale getirirse çağırır.
Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>)	İki veri akışı kaynağını izler ve sağlanan işleyiciyi hangi kaynak verileri önce kullanılabilir hale getirirse çağırır.
Encapsulate<TInput,TOutput>(ITargetBlock<TInput>, ISourceBlock<TOutput>)	Hedefi ve kaynağı tek bir yayıcıya kapsüller.
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.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	öğesini ISourceBlock<TOutput> belirtilen ITargetBlock<TInput>öğesine bağlar.
NullTarget<TInput>()	Ona sunulan tüm iletileri zaman uyumlu olarak kabul eden ve bunları düşüren bir hedef bloğu alır.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Kaynağı kullanılabilir çıkış için zaman uyumsuz olarak izleyen bir Task<TResult> sağlar.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	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>, 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, CancellationToken)	Belirtilen kaynaktan zaman uyumlu bir şekilde 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.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Belirli bir kaynaktan isteğe bağlı zaman aşımı süresini gözlemleyerek zaman uyumlu bir şekilde bir değer alır.
Receive<TOutput>(ISourceBlock<TOutput>)	Belirtilen kaynaktan zaman uyumlu olarak bir değer alır.
ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)	Kaynaktan tüm verilerin alınmasını sağlayan bir IAsyncEnumerable<T> oluşturur.
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, CancellationToken)	Belirli bir 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.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)	İsteğe bağlı zaman aşımı süresini gözlemleyerek belirtilen kaynaktan zaman uyumsuz olarak bir değer alır.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	Belirtilen kaynaktan zaman uyumsuz olarak bir değer alır.
SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken)	Zaman uyumsuz olarak hedef ileti bloğuna bir ileti sunar ve ertelemeye olanak tanır.
SendAsync<TInput>(ITargetBlock<TInput>, TInput)	Zaman uyumsuz olarak hedef ileti bloğuna bir ileti sunar ve ertelemeye olanak tanır.
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)	öğesinden ISourceBlock<TOutput>bir öğeyi zaman uyumlu bir şekilde almaya çalışır.