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