TransformManyBlock<TInput,TOutput> Klas
Definitie
Belangrijk
Bepaalde informatie heeft betrekking op een voorlopige productversie die aanzienlijk kan worden gewijzigd voordat deze wordt uitgebracht. Microsoft biedt geen enkele expliciete of impliciete garanties met betrekking tot de informatie die hier wordt verstrekt.
Biedt een gegevensstroomblok dat een opgegeven Func<T,TResult> gemachtigde aanroept voor elk ontvangen gegevenselement.
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)Type parameters
- TInput
Hiermee geeft u het type gegevens op dat door deze TransformManyBlock<TInput,TOutput>gegevens is ontvangen en beheerd.
- TOutput
Hiermee geeft u het type gegevensuitvoer op.TransformManyBlock<TInput,TOutput>
- Overname
-
TransformManyBlock<TInput,TOutput>
- Implementeringen
Opmerkingen
Note
De TPL-gegevensstroombibliotheek (de System.Threading.Tasks.Dataflow naamruimte) wordt niet gedistribueerd met .NET. Als u de System.Threading.Tasks.Dataflow-naamruimte in Visual Studio wilt installeren, opent u uw project, kiest u NuGet-pakketten beheren in het menu Project en zoekt u online naar het System.Threading.Tasks.Dataflow-pakket. Om deze te installeren met behulp van de .NET Core CLI, voert u dotnet add package System.Threading.Tasks.Dataflowuit.
Constructors
Eigenschappen
| Name | Description |
|---|---|
| Completion |
Hiermee wordt een Task bestand opgehaald dat de asynchrone bewerking en voltooiing van het gegevensstroomblok vertegenwoordigt. |
| InputCount |
Hiermee wordt het aantal invoeritems opgehaald dat moet worden verwerkt door dit blok. |
| OutputCount |
Hiermee haalt u het aantal uitvoeritems op dat beschikbaar is voor ontvangst van dit blok. |
Methoden
| Name | Description |
|---|---|
| Complete() |
Signalen voor het IDataflowBlock feit dat het niet meer berichten mag accepteren of produceren en geen uitgestelde berichten meer verbruiken. |
| Equals(Object) |
Bepaalt of het opgegeven object gelijk is aan het huidige object. (Overgenomen van Object) |
| GetHashCode() |
Fungeert als de standaardhashfunctie. (Overgenomen van Object) |
| GetType() |
Hiermee haalt u de Type huidige instantie op. (Overgenomen van Object) |
| LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions) |
Hiermee koppelt u de ISourceBlock<TOutput> opgegeven ITargetBlock<TInput> . |
| MemberwiseClone() |
Hiermee maakt u een ondiepe kopie van de huidige Object. (Overgenomen van Object) |
| ToString() |
Retourneert een tekenreeks die de opgemaakte naam van dit IDataflowBlock exemplaar vertegenwoordigt. |
| TryReceive(Predicate<TOutput>, TOutput) |
Pogingen om synchroon een beschikbaar uitvoeritem van de IReceivableSourceBlock<TOutput>. |
| TryReceiveAll(IList<TOutput>) |
Pogingen om alle beschikbare items synchroon te ontvangen van de IReceivableSourceBlock<TOutput>. |
Expliciete interface-implementaties
Extensiemethoden
| Name | Description |
|---|---|
| AsObservable<TOutput>(ISourceBlock<TOutput>) |
Hiermee maakt u een nieuwe IObservable<T> abstractie over de ISourceBlock<TOutput>. |
| AsObserver<TInput>(ITargetBlock<TInput>) |
Hiermee maakt u een nieuwe IObserver<T> abstractie over de ITargetBlock<TInput>. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>) |
Hiermee koppelt u de ISourceBlock<TOutput> opgegeven aan de opgegeven ITargetBlock<TInput> met behulp van het opgegeven filter. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>) |
Hiermee koppelt u de ISourceBlock<TOutput> opgegeven aan de opgegeven ITargetBlock<TInput> met behulp van het opgegeven filter. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>) |
Hiermee koppelt u de ISourceBlock<TOutput> opgegeven ITargetBlock<TInput>. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Biedt een Task<TResult> die asynchroon de bron bewaakt voor beschikbare uitvoer. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>) |
Biedt een Task<TResult> die asynchroon de bron bewaakt voor beschikbare uitvoer. |
| Post<TInput>(ITargetBlock<TInput>, TInput) |
Hiermee plaatst u een item in de ITargetBlock<TInput>. |
| Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Synchroon ontvangt een waarde van een opgegeven bron en biedt een token om de bewerking te annuleren. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Synchroon ontvangt een waarde van een opgegeven bron, waardoor een token wordt opgegeven om de bewerking te annuleren en een optioneel time-outinterval te observeren. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Synchroon ontvangt een waarde van een opgegeven bron, waarbij een optionele time-outperiode wordt waargenomen. |
| Receive<TOutput>(ISourceBlock<TOutput>) |
Hiermee ontvangt u synchroon een waarde van een opgegeven bron. |
| ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken) |
Hiermee maakt u een IAsyncEnumerable<T> bestand waarmee alle gegevens van de bron kunnen worden ontvangen. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Asynchroon ontvangt een waarde van een opgegeven bron en biedt een token om de bewerking te annuleren. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Asynchroon ontvangt een waarde van een opgegeven bron, waarbij een token wordt opgegeven om de bewerking te annuleren en een optioneel time-outinterval te observeren. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Asynchroon ontvangt een waarde van een opgegeven bron, waarbij een optionele time-outperiode wordt waargenomen. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>) |
Asynchroon ontvangt een waarde van een opgegeven bron. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken) |
Asynchroon biedt een bericht aan het doelberichtblok, waardoor uitstel mogelijk is. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput) |
Asynchroon biedt een bericht aan het doelberichtblok, waardoor uitstel mogelijk is. |
| TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput) |
Pogingen om een item synchroon te ontvangen van de ISourceBlock<TOutput>. |
