akka/akka-core
add possibility to BroadcastHub to retry last N records for every new consumer
オープン
#23,816 opened on 2017/10/17
3 - in progresshelp wantedt:stream
Repository metrics
- Stars
- (13,277 個のスター)
- PR merge metrics
- (平均マージ 8d 19h) (30d で 10 merged PRs)
説明
BroadcastHub is a class to create a sink for a dynamic set of consumers. In my case speed of data publishing is not so fast and I should retry last N records to every new consumer, so users will see records in any time.