ActionBlock<TInput>.ITargetBlock<TInput>.OfferMessage Méthode

Définition

Propose un message au bloc de flux de données et lui donne la possibilité de consommer ou de reporter le message.

 virtual System::Threading::Tasks::Dataflow::DataflowMessageStatus System.Threading.Tasks.Dataflow.ITargetBlock<TInput>.OfferMessage(System::Threading::Tasks::Dataflow::DataflowMessageHeader messageHeader, TInput messageValue, System::Threading::Tasks::Dataflow::ISourceBlock<TInput> ^ source, bool consumeToAccept) = System::Threading::Tasks::Dataflow::ITargetBlock<TInput>::OfferMessage;
System.Threading.Tasks.Dataflow.DataflowMessageStatus ITargetBlock<TInput>.OfferMessage(System.Threading.Tasks.Dataflow.DataflowMessageHeader messageHeader, TInput messageValue, System.Threading.Tasks.Dataflow.ISourceBlock<TInput> source, bool consumeToAccept);
abstract member System.Threading.Tasks.Dataflow.ITargetBlock<TInput>.OfferMessage : System.Threading.Tasks.Dataflow.DataflowMessageHeader * 'Input * System.Threading.Tasks.Dataflow.ISourceBlock<'Input> * bool -> System.Threading.Tasks.Dataflow.DataflowMessageStatus
override this.System.Threading.Tasks.Dataflow.ITargetBlock<TInput>.OfferMessage : System.Threading.Tasks.Dataflow.DataflowMessageHeader * 'Input * System.Threading.Tasks.Dataflow.ISourceBlock<'Input> * bool -> System.Threading.Tasks.Dataflow.DataflowMessageStatus
Function OfferMessage (messageHeader As DataflowMessageHeader, messageValue As TInput, source As ISourceBlock(Of TInput), consumeToAccept As Boolean) As DataflowMessageStatus Implements ITargetBlock(Of TInput).OfferMessage

Paramètres

messageHeader
DataflowMessageHeader

En-tête du message proposé.

messageValue
TInput

Valeur du message proposé.

source
ISourceBlock<TInput>

Bloc de flux de données qui offre le message. C’est peut-être nullle cas.

consumeToAccept
Boolean

true pour indiquer à la cible d’appeler ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean) de manière synchrone pendant l’appel à OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, Boolean), avant de retourner Accepted, afin de consommer le message ; sinon, false.

Retours

État du message proposé. Si le message a été accepté par la cible, Accepted est retourné et la source ne doit plus utiliser le message proposé, car il appartient maintenant à la cible. Si le message a été reporté par la cible, Postponed est retourné en tant que notification indiquant que la cible peut tenter ultérieurement de consommer ou de réserver le message ; en attendant, la source possède toujours le message et peut l’offrir à d’autres blocs.

Si la cible aurait autrement reporté le message, mais que la source était null, Declined est retournée.

Si la cible a essayé d’accepter le message mais l’a manqué en raison de la source qui remet le message à une autre cible ou simplement de l’ignorer, NotAvailable est retournée.

Si la cible a choisi de ne pas accepter le message, Declined elle est retournée. Si la cible a choisi de ne pas accepter le message et n’acceptera jamais un autre message de cette source, DecliningPermanently est retourné.

Implémente

Exceptions

messageHeader n’est pas valide.

-ou- consumeToAccept peut être true uniquement si fourni avec une valeur non null source.

S’applique à