BatchBlock<T>.ISourceBlock<T[]>.ConsumeMessage Methode

Referenz

Definition

Namespace:: System.Threading.Tasks.Dataflow

Assembly:: System.Threading.Tasks.Dataflow.dll

Paket:: System.Threading.Tasks.Dataflow v8.0.0

Paket:: System.Threading.Tasks.Dataflow v9.0.0-preview.3.24172.9

Quelle:: BatchBlock.cs

Quelle:: BatchBlock.cs

Quelle:: BatchBlock.cs

Wichtig

Einige Informationen beziehen sich auf Vorabversionen, die vor dem Release ggf. grundlegend überarbeitet werden. Microsoft übernimmt hinsichtlich der hier bereitgestellten Informationen keine Gewährleistungen, seien sie ausdrücklich oder konkludent.

Wird von einem verknüpften ITargetBlock<TInput>-Objekt aufgerufen, um ein DataflowMessageHeader-Objekt zu akzeptieren und zu verarbeiten, das zuvor durch dieses ISourceBlock<TOutput> angeboten wurde.

 virtual cli::array <T> ^ System.Threading.Tasks.Dataflow.ISourceBlock<T[]>.ConsumeMessage(System::Threading::Tasks::Dataflow::DataflowMessageHeader messageHeader, System::Threading::Tasks::Dataflow::ITargetBlock<cli::array <T> ^> ^ target, [Runtime::InteropServices::Out] bool % messageConsumed) = System::Threading::Tasks::Dataflow::ISourceBlock<cli::array <T> ^>::ConsumeMessage;

T[] ISourceBlock<T[]>.ConsumeMessage (System.Threading.Tasks.Dataflow.DataflowMessageHeader messageHeader, System.Threading.Tasks.Dataflow.ITargetBlock<T[]> target, out bool messageConsumed);

abstract member System.Threading.Tasks.Dataflow.ISourceBlock<T[]>.ConsumeMessage : System.Threading.Tasks.Dataflow.DataflowMessageHeader * System.Threading.Tasks.Dataflow.ITargetBlock<'T[]> * bool -> 'T[]
override this.System.Threading.Tasks.Dataflow.ISourceBlock<T[]>.ConsumeMessage : System.Threading.Tasks.Dataflow.DataflowMessageHeader * System.Threading.Tasks.Dataflow.ITargetBlock<'T[]> * bool -> 'T[]

Function ConsumeMessage (messageHeader As DataflowMessageHeader, target As ITargetBlock(Of T()), ByRef messageConsumed As Boolean) As T() Implements ISourceBlock(Of T()).ConsumeMessage

Parameter

messageHeader: DataflowMessageHeader

DataflowMessageHeader der Meldung, die verarbeitet wird.

target: ITargetBlock<T[]>

Die ITargetBlock<TInput>, die die Nachricht verwendet.

messageConsumed: Boolean

true, wenn die Nachricht erfolgreich verarbeitet wurde, andernfalls false.

Gibt zurück

T[]

Der Wert der verarbeiteten Meldung. Dies entspricht möglicherweise einer anderen DataflowMessageHeader-Instanz als die zuvor reservierte und die als messageHeader an ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean) übergebene. Der ITargetBlock<TInput> muss den zurückgegebenen Wert benutzen und nicht den Wert, der als messageValue von OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, Boolean) übergeben wird.

Wenn die Meldung, die angefordert wird, nicht verfügbar ist, ist der Rückgabewert null.

Implementiert

ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)

Ausnahmen

ArgumentException

Der messageHeader ist ungültig.

ArgumentNullException

target ist null.

Hinweise

Nur ITargetBlock<TInput> Instanzen, die mit dieser ISourceBlock<TOutput> Instanz verknüpft sind, können verwenden ConsumeMessage, und sie darf nur verwendet werden, um Instanzen zu nutzen DataflowMessageHeader , die zuvor von dieser Quelle für das Ziel angeboten wurden.

Gilt für:

Share via