search

devsisters / shardcake

Sharding and location transparency for Scala
https://devsisters.github.io/shardcake/
Apache License 2.0
389 stars 30 forks source link

Improve Streaming replies #75

Closed mleclercq closed 1 year ago

mleclercq commented 1 year ago
  1. add a Messenger.sendStreamAutoRestart that automatically restarts the stream on rebalance
  2. split Replier into two, the original Replier and a StreamReplier so we can't reply with a single response when a stream is expected or vise-versa