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

Referência

Definição

Namespace:: System.Threading.Tasks.Dataflow

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

Importante

Algumas informações se referem a produtos de pré-lançamento que podem ser substancialmente modificados antes do lançamento. A Microsoft não oferece garantias, expressas ou implícitas, das informações aqui fornecidas.

Passa a propriedade da mensagem identificada pelo DataflowMessageHeader desta instância de ISourceBlock<TOutput> para o 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

O DataflowMessageHeader da mensagem a ser consumida.

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

O ITargetBlock<TInput> para o qual a mensagem deverá ser consumida.

messageConsumed: Boolean

true se a mensagem foi consumida com êxito. false caso contrário.

Retornos

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

O valor da mensagem consumida. Pode corresponder a uma instância DataflowMessageHeader diferente do que foi reservado anteriormente e passado como o messageHeader para este método. O ITargetBlock<TInput> de consumo deve usar o valor retornado em vez do valor passado como messageValue para OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, Boolean). Se a mensagem solicitada não estiver disponível, o valor retornado será null (Nothing em Visual Basic).

Implementações

ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)

Exceções

ArgumentException

O messageHeader não é válido.

ArgumentNullException

The target is null (Nothing in Visual Basic).

Comentários

A ITargetBlock<TInput> mensagem para a qual a mensagem deve ser consumida não precisa ser vinculada dessa ISourceBlock<TOutput> instância. Além disso, essa ISourceBlock<TOutput> instância pode nunca ter oferecido a mensagem diretamente ao ITargetBlock<TInput>.

Aplica-se a

Partilhar via