CRDT streams

[mikevoronov]

AIR streams have no guarantees of ordering. Consider the following script

(seq
  (fold peers peer
    (par
       (call peer ("service" "function") [args] $stream)
       (next peer)
    )
  )
  (call %init_peer_id% ("" "") [$stream])
)

Assuming that peers contains some peer ids, executing this scripts will result a non-deterministic $stream content on %init_peer_id%, that depends on particle ordering.

According to the AIR philosophy and gurantees, it's better to introduce a CRDT-like streams that would have the consistent order on each peer, but they could differ on different peers.

[mikevoronov]

Fixed by #74