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

Referência

Definição

Namespace:: System.Threading.Tasks.Dataflow

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

Pacote:: System.Threading.Tasks.Dataflow v8.0.1

Pacote:: System.Threading.Tasks.Dataflow v9.0.0-rc.2.24473.5

Origem:: BatchedJoinBlock.cs

Origem:: BatchedJoinBlock.cs

Origem:: BatchedJoinBlock.cs

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 dessa ISourceBlock<TOutput> instância para o ITargetBlock<TInput>.

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

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

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

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

Parâmetros

messageHeader: DataflowMessageHeader

O DataflowMessageHeader da mensagem a ser consumida.

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

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>,IList<T3>>

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

O target é null (Nothing no Visual Basic).

Comentários

O ITargetBlock<TInput> para o qual a mensagem deve ser consumida não precisa ser vinculado a partir 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

Compartilhar via