TransformBlock<TInput,TOutput> Klass

Definition

Tillhandahåller ett dataflödesblock som anropar ett angivet Func<T,TResult> ombud för varje dataelement som tas emot.

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)

Typparametrar

TInput

Anger vilken typ av data som tas emot och drivs av den här TransformBlock<TInput,TOutput>.

TOutput

Anger typen av datautdata med den här TransformBlock<TInput,TOutput>.

Arv
TransformBlock<TInput,TOutput>
Implementeringar

Kommentarer

Note

TPL-dataflödesbiblioteket (System.Threading.Tasks.Dataflow-namnområdet) distribueras inte med .NET. Om du vill installera System.Threading.Tasks.Dataflow-namnområdet i Visual Studio öppnar du projektet, väljer Hantera NuGet-paket från menyn Project och söker online efter System.Threading.Tasks.Dataflow-paketet. Alternativt, för att installera det med hjälp av .NET Core CLI, kör dotnet add package System.Threading.Tasks.Dataflow.

Konstruktorer

Name Description
TransformBlock<TInput,TOutput>(Func<TInput,Task<TOutput>>, ExecutionDataflowBlockOptions)

Initierar en ny TransformBlock<TInput,TOutput> med angiven Func<T,TResult> och ExecutionDataflowBlockOptions.

TransformBlock<TInput,TOutput>(Func<TInput,Task<TOutput>>)

Initierar en ny TransformBlock<TInput,TOutput> med angiven Func<T,TResult>.

TransformBlock<TInput,TOutput>(Func<TInput,TOutput>, ExecutionDataflowBlockOptions)

Initierar en ny TransformBlock<TInput,TOutput> med angiven Func<T,TResult> och ExecutionDataflowBlockOptions.

TransformBlock<TInput,TOutput>(Func<TInput,TOutput>)

Initierar en ny TransformBlock<TInput,TOutput> med angiven Func<T,TResult>.

Egenskaper

Name Description
Completion

Hämtar en Task som representerar den asynkrona åtgärden och slutförandet av dataflödesblocket.

InputCount

Hämtar antalet indataobjekt som väntar på att bearbetas av det här blocket.

OutputCount

Hämtar antalet tillgängliga utdataobjekt som ska tas emot från det här blocket.

Metoder

Name Description
Complete()

Signaler till att den IDataflowBlock inte bör acceptera eller producera fler meddelanden eller förbruka fler uppskjutna meddelanden.

Equals(Object)

Avgör om det angivna objektet är lika med det aktuella objektet.

(Ärvd från Object)
GetHashCode()

Fungerar som standard-hash-funktion.

(Ärvd från Object)
GetType()

Hämtar den aktuella instansen Type .

(Ärvd från Object)
LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)

ISourceBlock<TOutput> Länkar till angiven ITargetBlock<TInput> .

MemberwiseClone()

Skapar en ytlig kopia av den aktuella Object.

(Ärvd från Object)
ToString()

Returnerar en sträng som representerar det formaterade namnet på den här IDataflowBlock instansen.

TryReceive(Predicate<TOutput>, TOutput)

Försök att synkront ta emot ett tillgängligt utdataobjekt från IReceivableSourceBlock<TOutput>.

TryReceiveAll(IList<TOutput>)

Försöker ta emot alla tillgängliga objekt synkront från IReceivableSourceBlock<TOutput>.

Explicita gränssnittsimplementeringar

Name Description
IDataflowBlock.Fault(Exception)

Gör att den IDataflowBlock slutförs i ett Faulted tillstånd.

ISourceBlock<TOutput>.ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)

Anropas av en länkad ITargetBlock<TInput> för att acceptera och använda en DataflowMessageHeader tidigare erbjuden av denna ISourceBlock<TOutput>.

ISourceBlock<TOutput>.ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)

Anropas av en länkad ITargetBlock<TInput> för att släppa en tidigare reserverad DataflowMessageHeader av denna ISourceBlock<TOutput>.

ISourceBlock<TOutput>.ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)

Anropas av en länkad ITargetBlock<TInput> till reservera en tidigare erbjuden DataflowMessageHeader av denna ISourceBlock<TOutput>.

ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, Boolean)

Erbjuder ett meddelande till ITargetBlock<TInput>, vilket ger målet möjlighet att använda eller skjuta upp meddelandet.

Tilläggsmetoder

Name Description
AsObservable<TOutput>(ISourceBlock<TOutput>)

Skapar en ny IObservable<T> abstraktion över ISourceBlock<TOutput>.

AsObserver<TInput>(ITargetBlock<TInput>)

Skapar en ny IObserver<T> abstraktion över ITargetBlock<TInput>.

LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)

ISourceBlock<TOutput> Länkar till det angivna ITargetBlock<TInput> med det angivna filtret.

LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)

ISourceBlock<TOutput> Länkar till det angivna ITargetBlock<TInput> med det angivna filtret.

LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)

ISourceBlock<TOutput> Länkar till angiven ITargetBlock<TInput>.

OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)

Tillhandahåller en Task<TResult> som asynkront övervakar källan för tillgängliga utdata.

OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)

Tillhandahåller en Task<TResult> som asynkront övervakar källan för tillgängliga utdata.

Post<TInput>(ITargetBlock<TInput>, TInput)

Publicerar ett objekt i ITargetBlock<TInput>.

Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)

Tar synkront emot ett värde från en angiven källa och tillhandahåller en token för att avbryta åtgärden.

Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)

Tar synkront emot ett värde från en angiven källa, vilket ger en token för att avbryta åtgärden och observerar ett valfritt tidsgränsintervall.

Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)

Tar synkront emot ett värde från en angiven källa och observerar en valfri tidsgräns.

Receive<TOutput>(ISourceBlock<TOutput>)

Tar synkront emot ett värde från en angiven källa.

ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)

Skapar en IAsyncEnumerable<T> som gör det möjligt att ta emot alla data från källan.

ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)

Tar asynkront emot ett värde från en angiven källa och tillhandahåller en token för att avbryta åtgärden.

ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)

Asynkront tar emot ett värde från en angiven källa, vilket ger en token för att avbryta åtgärden och observera ett valfritt tidsgränsintervall.

ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)

Tar asynkront emot ett värde från en angiven källa och observerar en valfri tidsgräns.

ReceiveAsync<TOutput>(ISourceBlock<TOutput>)

Tar asynkront emot ett värde från en angiven källa.

SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken)

Asynkront erbjuder ett meddelande till målmeddelandeblocket, vilket möjliggör senareläggning.

SendAsync<TInput>(ITargetBlock<TInput>, TInput)

Asynkront erbjuder ett meddelande till målmeddelandeblocket, vilket möjliggör senareläggning.

TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)

Försöker ta emot ett objekt synkront från ISourceBlock<TOutput>.

Gäller för