monix

0熱度

2回答

限制使用Monix Observable的.onErrorRestartIf時的重試次數？

Monix可觀測量具有頂點.onErrorRestartIf(f: Throwable => Boolean)和.onErrorRestart(times: Int)。如何指定它應該重試的最大次數.onErrorRestartIf？

0熱度

2回答

我已經使用monix和akka-streams將List [ClassA]映射到List [ClassB]的基準，但我不明白它爲什麼如此緩慢。我嘗試了不同的方法來映射，這裏是與江鈴控股的結果： [info] Benchmark Mode Cnt Score Error Units [info] MappingBenchmark.akkaLoadBalanceMap ss 2

0熱度

1回答

如何播放一個冷觀察：用背壓重播？

我實際上使用的是Scala，但這個問題對所有的Rx和流式框架都是通用的。我的用例是我有一個生成的observable（因此冷），我想多個消費者並行使用完全相同的值，但我希望他們有顯着不同的吞吐量。我需要的可以通過廣播一個可重放的observable來完成，但是我發現帶有最大緩衝區大小的重播策略是從緩衝區中溢出元素（然後爲最慢的消費者丟失）而不是反壓制片商。如果你把所有廣播的觀察對象視爲熱點，這是