TransformManyBlock<TInput,TOutput> Sınıf
Tanım
Önemli
Bazı bilgiler ürünün ön sürümüyle ilgilidir ve sürüm öncesinde önemli değişiklikler yapılmış olabilir. Burada verilen bilgilerle ilgili olarak Microsoft açık veya zımni hiçbir garanti vermez.
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>type TransformManyBlock<'Input, 'Output> = class
interface IDataflowBlock
interface IPropagatorBlock<'Input, 'Output>
interface ISourceBlock<'Output>
interface ITargetBlock<'Input>
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ışı türünü belirtir.
- Devralma
-
TransformManyBlock<TInput,TOutput>
- Uygulamalar
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.
Oluşturucular
Özellikler
| Name | Description |
|---|---|
| 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
| Name | Description |
|---|---|
| Complete() |
IDataflowBlock daha fazla ileti kabul etmemesi veya üretmemesi ya da ertelenmiş iletileri kullanmaması 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() |
Geçerli örneğin Type alır. (Devralındığı yer: Object) |
| LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions) |
öğesini ISourceBlock<TOutput> belirtilen ITargetBlock<TInput> öğesine bağlar. |
| MemberwiseClone() |
Geçerli Objectbasit 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 bir şekilde kullanılabilir bir çıkış öğesi almaya çalışır. |
| TryReceiveAll(IList<TOutput>) |
öğesinden IReceivableSourceBlock<TOutput>tüm kullanılabilir öğeleri zaman uyumlu bir şekilde almaya çalışır. |
Belirtik Arabirim Kullanımları
Uzantı Metotları
| 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. |
| 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. |
| 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. |
