TransformManyBlock<TInput,TOutput> 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 v9.0.0-preview.3.24172.9

Kaynak:

TransformManyBlock.cs

Alınan her veri öğesi için sağlanan Func<T,TResult> bir temsilciyi çağıran bir veri akışı bloğu sağlar.

generic <typename TInput, typename TOutput>
public ref class TransformManyBlock sealed : System::Threading::Tasks::Dataflow::IPropagatorBlock<TInput, TOutput>, System::Threading::Tasks::Dataflow::IReceivableSourceBlock<TOutput>, System::Threading::Tasks::Dataflow::ISourceBlock<TOutput>, System::Threading::Tasks::Dataflow::ITargetBlock<TInput>

public sealed class TransformManyBlock<TInput,TOutput> : System.Threading.Tasks.Dataflow.IPropagatorBlock<TInput,TOutput>, System.Threading.Tasks.Dataflow.IReceivableSourceBlock<TOutput>, System.Threading.Tasks.Dataflow.ISourceBlock<TOutput>, System.Threading.Tasks.Dataflow.ITargetBlock<TInput>

type TransformManyBlock<'Input, 'Output> = class
    interface IPropagatorBlock<'Input, 'Output>
    interface ITargetBlock<'Input>
    interface IDataflowBlock
    interface ISourceBlock<'Output>
    interface IReceivableSourceBlock<'Output>

Public NotInheritable Class TransformManyBlock(Of TInput, TOutput)
Implements IPropagatorBlock(Of TInput, TOutput), IReceivableSourceBlock(Of TOutput), ISourceBlock(Of TOutput), ITargetBlock(Of TInput)

Tür Parametreleri

TInput

Bu TransformManyBlock<TInput,TOutput>tarafından alınan ve üzerinde çalıştırılan verilerin türünü belirtir.

TOutput

Bu TransformManyBlock<TInput,TOutput>tarafından veri çıkışının türünü belirtir.

Devralma

Object

TransformManyBlock<TInput,TOutput>

Uygulamalar

IDataflowBlock IPropagatorBlock<TInput,TOutput> IReceivableSourceBlock<TOutput> ISourceBlock<TOutput> ITargetBlock<TInput>

Açıklamalar

Not

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

Oluşturucular

TransformManyBlock<TInput,TOutput>(Func<TInput,IAsyncEnumerable<TOutput>>)	belirtilen işlevle öğesini TransformManyBlock<TInput,TOutput> başlatır.
TransformManyBlock<TInput,TOutput>(Func<TInput,IAsyncEnumerable<TOutput>>, ExecutionDataflowBlockOptions)	belirtilen işlevi ve ExecutionDataflowBlockOptionsile başlatırTransformManyBlock<TInput,TOutput>.
TransformManyBlock<TInput,TOutput>(Func<TInput,IEnumerable<TOutput>>)	Belirtilen işlevle yeni TransformManyBlock<TInput,TOutput> bir başlatır.
TransformManyBlock<TInput,TOutput>(Func<TInput,IEnumerable<TOutput>>, ExecutionDataflowBlockOptions)	Belirtilen işlev ve ExecutionDataflowBlockOptionsile yeni TransformManyBlock<TInput,TOutput> bir başlatır.
TransformManyBlock<TInput,TOutput>(Func<TInput,Task<IEnumerable<TOutput>>>)	Belirtilen işlevle yeni TransformManyBlock<TInput,TOutput> bir başlatır.
TransformManyBlock<TInput,TOutput>(Func<TInput,Task<IEnumerable<TOutput>>>, ExecutionDataflowBlockOptions)	Belirtilen işlev ve ExecutionDataflowBlockOptionsile yeni TransformManyBlock<TInput,TOutput> bir başlatır.

Özellikler

Completion	Zaman uyumsuz işlemi ve veri akışı bloğunun tamamlanmasını temsil eden bir Task alır.
InputCount	Bu blok tarafından işlenmeyi bekleyen giriş öğelerinin sayısını alır.
OutputCount	Bu bloktan alınabilecek çıkış öğelerinin sayısını alır.

Yöntemler

Complete()	IDataflowBlock Kabul edilmemesi, daha fazla ileti üretilmemesi veya ertelenmiş iletilerin tüketilmemesi gerektiğine dair sinyaller.
Equals(Object)	Belirtilen nesnenin geçerli nesneye eşit olup olmadığını belirler. (Devralındığı yer: Object)
GetHashCode()	Varsayılan karma işlevi işlevi görür. (Devralındığı yer: Object)
GetType()	Type Geçerli örneğini alır. (Devralındığı yer: Object)
LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)	öğesini ISourceBlock<TOutput> belirtilen ITargetBlock<TInput> öğesine bağlar.
MemberwiseClone()	Geçerli Objectöğesinin sığ bir kopyasını oluşturur. (Devralındığı yer: Object)
ToString()	Bu IDataflowBlock örneğin biçimlendirilmiş adını temsil eden bir dize döndürür.
TryReceive(Predicate<TOutput>, TOutput)	öğesinden IReceivableSourceBlock<TOutput>zaman uyumlu olarak kullanılabilir bir çıkış öğesi almaya çalışır.
TryReceiveAll(IList<TOutput>)	öğesinden IReceivableSourceBlock<TOutput>tüm kullanılabilir öğeleri zaman uyumlu olarak almaya çalışır.

Belirtik Arabirim Kullanımları

IDataflowBlock.Fault(Exception)	durumunda IDataflowBlock tamamlanmasına Faulted neden olur.
ISourceBlock<TOutput>.ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)	Bu tarafından daha önce sunulan bir DataflowMessageHeader kabul etmek ve kullanmak için bağlı ITargetBlock<TInput> tarafından çağrılırISourceBlock<TOutput>.
ISourceBlock<TOutput>.ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)	Daha önce bu tarafından ayrılmış DataflowMessageHeader bir sürümü yayınlamak için bir bağlı ITargetBlock<TInput> tarafından çağrılırISourceBlock<TOutput>.
ISourceBlock<TOutput>.ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)	Daha önce bu tarafından sunulan bir ayırmak için bağlı ITargetBlock<TInput> tarafından çağrılır DataflowMessageHeaderISourceBlock<TOutput>.
ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, Boolean)	hedefine ITargetBlock<TInput>iletiyi kullanma veya erteleme fırsatı veren bir ileti sunar.

Uzantı Metotları

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.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	öğesini ISourceBlock<TOutput> belirtilen ITargetBlock<TInput>öğesine 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>, DataflowLinkOptions, Predicate<TOutput>)	ISourceBlock<TOutput> belirtilen filtreyi kullanarak öğesini belirtilene ITargetBlock<TInput> bağlar.
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.