BatchedJoinBlock<T1,T2,T3>.ISourceBlock<Tuple<IList<T1>,IList<T2>,IList<T3>>>.ConsumeMessage Метод

Ссылка

Определение

Пространство имен:: System.Threading.Tasks.Dataflow

Сборка:: System.Threading.Tasks.Dataflow.dll

Пакет:: System.Threading.Tasks.Dataflow v8.0.0

Пакет:: System.Threading.Tasks.Dataflow v9.0.0-preview.3.24172.9

Исходный код:: BatchedJoinBlock.cs

Исходный код:: BatchedJoinBlock.cs

Исходный код:: BatchedJoinBlock.cs

Важно!

Некоторые сведения относятся к предварительной версии продукта, в которую до выпуска могут быть внесены существенные изменения. Майкрософт не предоставляет никаких гарантий, явных или подразумеваемых, относительно приведенных здесь сведений.

Передает владение сообщением, определяемым классом DataflowMessageHeader , из этого ISourceBlock<TOutput> экземпляра в 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

Параметры

messageHeader: DataflowMessageHeader

Объект DataflowMessageHeader сообщения, которое требуется получить.

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

Объект ITargetBlock<TInput>, для которого будет получено сообщение.

messageConsumed: Boolean

Значение true, если сообщение было успешно получено. В противном случае — значение false.

Возвращаемое значение

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

Значение получаемого сообщения. Это может соответствовать другому экземпляру DataflowMessageHeader, отличающемуся от ранее зарезервированного и переданного в качестве параметра messageHeader этому методу. Рассматриваемый ITargetBlock<TInput> должен использовать возвращаемое значение вместо значения, переданного как messageValue в OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, Boolean). Если запрошенное сообщение недоступно, возвращается значение null (Nothing в Visual Basic).

Реализации

ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)

Исключения

ArgumentException

Недопустимое значение messageHeader.

ArgumentNullException

target имеет значение null (nothing в Visual Basic).

Объект ITargetBlock<TInput> , для которого должно использоваться сообщение, не должен быть связан с этим ISourceBlock<TOutput> экземпляром. Кроме того, этот ISourceBlock<TOutput> экземпляр, возможно, никогда не предоставлял сообщение непосредственно в ITargetBlock<TInput>.

Применяется к