BatchedJoinBlock<T1,T2>.ISourceBlock<Tuple<IList<T1>,IList<T2>>>.ConsumeMessage Método

Referencia

Definición

Espacio de nombres:: System.Threading.Tasks.Dataflow

Ensamblado:: System.Threading.Tasks.Dataflow.dll

Importante

Parte de la información hace referencia a la versión preliminar del producto, que puede haberse modificado sustancialmente antes de lanzar la versión definitiva. Microsoft no otorga ninguna garantía, explícita o implícita, con respecto a la información proporcionada aquí.

Pasa la propiedad del mensaje identificado por DataflowMessageHeader de esta instancia de ISourceBlock<TOutput> a ITargetBlock<TInput>.

 virtual Tuple<System::Collections::Generic::IList<T1> ^, System::Collections::Generic::IList<T2> ^> ^ System.Threading.Tasks.Dataflow.ISourceBlock<System.Tuple<System.Collections.Generic.IList<T1>,System.Collections.Generic.IList<T2>>>.ConsumeMessage(System::Threading::Tasks::Dataflow::DataflowMessageHeader messageHeader, System::Threading::Tasks::Dataflow::ITargetBlock<Tuple<System::Collections::Generic::IList<T1> ^, System::Collections::Generic::IList<T2> ^> ^> ^ target, [Runtime::InteropServices::Out] bool % messageConsumed) = System::Threading::Tasks::Dataflow::ISourceBlock<Tuple<System::Collections::Generic::IList<T1> ^, System::Collections::Generic::IList<T2> ^> ^>::ConsumeMessage;

Tuple<System.Collections.Generic.IList<T1>,System.Collections.Generic.IList<T2>> ISourceBlock<Tuple<IList<T1>,IList<T2>>>.ConsumeMessage (System.Threading.Tasks.Dataflow.DataflowMessageHeader messageHeader, System.Threading.Tasks.Dataflow.ITargetBlock<Tuple<System.Collections.Generic.IList<T1>,System.Collections.Generic.IList<T2>>> target, out bool messageConsumed);

abstract member System.Threading.Tasks.Dataflow.ISourceBlock<System.Tuple<System.Collections.Generic.IList<T1>,System.Collections.Generic.IList<T2>>>.ConsumeMessage : System.Threading.Tasks.Dataflow.DataflowMessageHeader * System.Threading.Tasks.Dataflow.ITargetBlock<System.Collections.Generic.IList<'T1> * System.Collections.Generic.IList<'T2>> * bool -> System.Collections.Generic.IList<'T1> * System.Collections.Generic.IList<'T2>
override this.System.Threading.Tasks.Dataflow.ISourceBlock<System.Tuple<System.Collections.Generic.IList<T1>,System.Collections.Generic.IList<T2>>>.ConsumeMessage : System.Threading.Tasks.Dataflow.DataflowMessageHeader * System.Threading.Tasks.Dataflow.ITargetBlock<System.Collections.Generic.IList<'T1> * System.Collections.Generic.IList<'T2>> * bool -> System.Collections.Generic.IList<'T1> * System.Collections.Generic.IList<'T2>

Function ConsumeMessage (messageHeader As DataflowMessageHeader, target As ITargetBlock(Of Tuple(Of IList(Of T1), IList(Of T2))), ByRef messageConsumed As Boolean) As Tuple(Of IList(Of T1), IList(Of T2)) Implements ISourceBlock(Of Tuple(Of IList(Of T1), IList(Of T2))).ConsumeMessage

Parámetros

messageHeader: DataflowMessageHeader

DataflowMessageHeader del mensaje que se va a consumir.

target: ITargetBlock<Tuple<IList<T1>,IList<T2>>>

ITargetBlock<TInput> para el que se va a consumir el mensaje.

messageConsumed: Boolean

true si se ha consumido correctamente el mensaje. En caso contrario, es false.

Devoluciones

Tuple<IList<T1>,IList<T2>>

Valor del mensaje consumido. Esto puede corresponder a una instancia de DataflowMessageHeader diferente de la reservada previamente y que se pasó como messageHeader a este método. El objeto ITargetBlock<TInput> de consumo debe usar el valor devuelto en lugar del valor pasado como messageValue a OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, Boolean). Si el mensaje solicitado no está disponible, el valor devuelto es null (Nothing en Visual Basic).

Implementaciones

ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)

Excepciones

ArgumentException

messageHeader no es válido.

ArgumentNullException

target es null (Nothing en Visual Basic).

Comentarios

No ITargetBlock<TInput> es necesario vincular el elemento para el que se va a consumir el mensaje desde esta ISourceBlock<TOutput> instancia. Además, es posible que esta ISourceBlock<TOutput> instancia nunca haya ofrecido el mensaje directamente a .ITargetBlock<TInput>

Se aplica a

Compartir a través de