head lag observer throttling (#169)
This commit is contained in:
@@ -57,6 +57,7 @@ abstract class HeadLagObserver(
|
|||||||
|
|
||||||
fun subscription(): Flux<Unit> {
|
fun subscription(): Flux<Unit> {
|
||||||
return master.getFlux()
|
return master.getFlux()
|
||||||
|
.sample(Duration.ofSeconds(5))
|
||||||
.flatMap(this::probeFollowers)
|
.flatMap(this::probeFollowers)
|
||||||
.map { item ->
|
.map { item ->
|
||||||
item.t2.setLag(item.t1)
|
item.t2.setLag(item.t1)
|
||||||
|
|||||||
Reference in New Issue
Block a user