Functionality of Combine Operator &>- in Axum


the axum documentation says " combine operator takes vector of sources, receives message each, packages them array , forwards result right hand operator."

let's assume eample that vector of sources , b.

what result of combine opertor when recieves 2 messages before b recieves one? combine operator send first message sent or recent (second) one?

what result of combine operator when receives 2 messages , b receives two? 1 package array sent, or 2 sent?

it impotant know details of combine opertor actions in case of out of sequence , multiple message combinations. functionality of application may dependent on behavior , bugs may difficult diagnose , reproduce.

is possible specify or configure behavior of combine operator in case of out of sequence messages?

the documentation correct , specified perspective of operator itself. of questions ask depend on circumstances outside operator. let use network "{a,b} &>- c" our example.

you ask:

what result of combine opertor when recieves 2 messages before b recieves one? combine operator send first message sent or recent (second) one?

the answer depends on source a: unbounded buffer, example, guarantee in-order delivery, hold first value until b produces 1 and both can consumed. single item interaction point, on other hand, allow linked targets (such combine operator) consume last value.

you ask:

what result of combine operator when receives 2 messages , b receives two? 1 package array sent, or 2 sent?

that depends on how target of combine operator linked: default, using language constructs, keep sending until network {a,b} &>- c disposed , connection c unlinked. however, if disassembles compiler generating, possible figure out how create underlying objects directly , create transient link combine block, means c first tuple {a,b}. language construct streams until network torn down, underlying infrastructure supports both.

niklas

 



Archived Forums A-B  >  Axum Incubation Project



Comments

Popular posts from this blog

Azure DocumentDB Owner resource does not exist

BizTalk Server 2013 Azure VM Log Shipping and HA for hosts

How to send non-standard Content-Type header ?