TransformBlock<TInput,TOutput> Osztály
Definíció
Fontos
Egyes információk olyan, kiadás előtti termékekre vonatkoznak, amelyek a kiadásig még jelentősen módosulhatnak. A Microsoft nem vállal kifejezett vagy törvényi garanciát az itt megjelenő információért.
Egy adatfolyamblokkot biztosít, amely minden fogadott adatelemhez meghív egy megadott Func<T,TResult> meghatalmazottat.
generic <typename TInput, typename TOutput>
public ref class TransformBlock 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 TransformBlock<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 TransformBlock<'Input, 'Output> = class
interface IPropagatorBlock<'Input, 'Output>
interface ITargetBlock<'Input>
interface IDataflowBlock
interface ISourceBlock<'Output>
interface IReceivableSourceBlock<'Output>
type TransformBlock<'Input, 'Output> = class
interface IDataflowBlock
interface IPropagatorBlock<'Input, 'Output>
interface ISourceBlock<'Output>
interface ITargetBlock<'Input>
interface IReceivableSourceBlock<'Output>
Public NotInheritable Class TransformBlock(Of TInput, TOutput)
Implements IPropagatorBlock(Of TInput, TOutput), IReceivableSourceBlock(Of TOutput), ISourceBlock(Of TOutput), ITargetBlock(Of TInput)
Típusparaméterek
- TInput
A fogadott és az általuk TransformBlock<TInput,TOutput>kezelt adatok típusát adja meg.
- TOutput
Az adatkimenet típusát adja meg ezzel a TransformBlock<TInput,TOutput>beállítással.
- Öröklődés
-
TransformBlock<TInput,TOutput>
- Megvalósítás
Megjegyzések
Note
A TPL-adatfolyamtár (a System.Threading.Tasks.Dataflow névtér) nincs elosztva a .NET-tel. Ha telepíteni szeretné a System.Threading.Tasks.Dataflow névteret a Visual Studióban, nyissa meg a projektet, válassza NuGet-csomagok kezelése a Project menüjében, és keressen online a System.Threading.Tasks.Dataflow csomagra. Másik lehetőségként a .NET Core CLI használatával telepítheti, futtassa a dotnet add package System.Threading.Tasks.Dataflow.
Konstruktorok
| Name | Description |
|---|---|
| TransformBlock<TInput,TOutput>(Func<TInput,Task<TOutput>>, ExecutionDataflowBlockOptions) |
Inicializál egy újat TransformBlock<TInput,TOutput> a megadott Func<T,TResult> és ExecutionDataflowBlockOptionsa . |
| TransformBlock<TInput,TOutput>(Func<TInput,Task<TOutput>>) |
Inicializál egy újat TransformBlock<TInput,TOutput> a megadottval Func<T,TResult>. |
| TransformBlock<TInput,TOutput>(Func<TInput,TOutput>, ExecutionDataflowBlockOptions) |
Inicializál egy újat TransformBlock<TInput,TOutput> a megadott Func<T,TResult> és ExecutionDataflowBlockOptionsa . |
| TransformBlock<TInput,TOutput>(Func<TInput,TOutput>) |
Inicializál egy újat TransformBlock<TInput,TOutput> a megadottval Func<T,TResult>. |
Tulajdonságok
| Name | Description |
|---|---|
| Completion |
Task Lekéri az adatfolyam-blokk aszinkron műveletét és befejezését ábrázoló értéket. |
| InputCount |
Lekéri a blokk által feldolgozandó bemeneti elemek számát. |
| OutputCount |
Lekéri a blokkból fogadandó kimeneti elemek számát. |
Metódusok
| Name | Description |
|---|---|
| Complete() |
Azt jelzi IDataflowBlock , hogy nem fogadhat el és nem hozhat létre több üzenetet, és nem használ fel több elhalasztott üzenetet. |
| Equals(Object) |
Meghatározza, hogy a megadott objektum egyenlő-e az aktuális objektummal. (Öröklődés forrása Object) |
| GetHashCode() |
Ez az alapértelmezett kivonatoló függvény. (Öröklődés forrása Object) |
| GetType() |
Lekéri az Type aktuális példányt. (Öröklődés forrása Object) |
| LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions) |
A megadotthoz csatolja a ISourceBlock<TOutput> elemet ITargetBlock<TInput> . |
| MemberwiseClone() |
Az aktuális Objectpéldány sekély másolatát hozza létre. (Öröklődés forrása Object) |
| ToString() |
Egy sztringet ad vissza, amely a példány formázott nevét IDataflowBlock jelöli. |
| TryReceive(Predicate<TOutput>, TOutput) |
Egy elérhető kimeneti elem szinkronizálási kísérlete a IReceivableSourceBlock<TOutput>. |
| TryReceiveAll(IList<TOutput>) |
Az összes rendelkezésre álló elem szinkron fogadására tett kísérletek a IReceivableSourceBlock<TOutput>. |
Explicit interfész-implementációk
Bővítő metódusok
| Name | Description |
|---|---|
| AsObservable<TOutput>(ISourceBlock<TOutput>) |
Új IObservable<T> absztrakciót hoz létre a ISourceBlock<TOutput>. |
| AsObserver<TInput>(ITargetBlock<TInput>) |
Új IObserver<T> absztrakciót hoz létre a ITargetBlock<TInput>. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>) |
A megadott szűrővel csatolja a ISourceBlock<TOutput> megadotthoz ITargetBlock<TInput> . |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>) |
A megadott szűrővel csatolja a ISourceBlock<TOutput> megadotthoz ITargetBlock<TInput> . |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>) |
A megadotthoz csatolja a ISourceBlock<TOutput> elemet ITargetBlock<TInput>. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Task<TResult> A rendelkezésre álló kimenet forrását aszinkron módon figyeli. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>) |
Task<TResult> A rendelkezésre álló kimenet forrását aszinkron módon figyeli. |
| Post<TInput>(ITargetBlock<TInput>, TInput) |
Elem bejegyzése a következőre: .> |
| Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Szinkron módon kap egy értéket egy megadott forrástól, és egy jogkivonatot biztosít a művelet megszakításához. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Szinkron módon kap egy értéket egy megadott forrástól, amely egy jogkivonatot biztosít a művelet megszakításához és egy opcionális időtúllépési időköz megfigyeléséhez. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Szinkron módon kap egy értéket egy megadott forrástól, figyelembe véve az opcionális időtúllépési időszakot. |
| Receive<TOutput>(ISourceBlock<TOutput>) |
Szinkron módon kap egy értéket egy megadott forrásból. |
| ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken) |
Létrehoz egy olyan alkalmazást IAsyncEnumerable<T> , amely lehetővé teszi az összes adat fogadását a forrásból. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Aszinkron módon kap egy értéket egy megadott forrástól, és egy jogkivonatot biztosít a művelet megszakításához. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Aszinkron módon kap egy értéket egy megadott forrástól, amely jogkivonatot biztosít a művelet megszakításához és egy opcionális időtúllépési időköz megfigyeléséhez. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Aszinkron módon kap egy értéket egy megadott forrástól, egy opcionális időtúllépési időszakot figyelve. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>) |
Aszinkron módon egy adott forrásból kap értéket. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken) |
Aszinkron módon üzenetet küld a célüzenetblokknak, ami lehetővé teszi a halasztást. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput) |
Aszinkron módon üzenetet küld a célüzenetblokknak, ami lehetővé teszi a halasztást. |
| TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput) |
Megkísérli szinkronizálva fogadni az elemet a ISourceBlock<TOutput>. |