diff --git a/examples/lightpush_publisher_mix.nim b/examples/lightpush_publisher_mix.nim index 7a7bdfb2f..a91b994fe 100644 --- a/examples/lightpush_publisher_mix.nim +++ b/examples/lightpush_publisher_mix.nim @@ -159,7 +159,7 @@ proc setupAndPublish(rng: ref HmacDrbgContext, conf: LPMixConf) {.async.} = error "failed to publish message", error = res.error lp_mix_failed.inc(labelValues = ["publish_error"]) - await sleepAsync(1000) + await sleepAsync(conf.msgInterval) info "###########Sent all messages via mix" quit(0) diff --git a/examples/lightpush_publisher_mix_config.nim b/examples/lightpush_publisher_mix_config.nim index 9d94d20b1..63b59f730 100644 --- a/examples/lightpush_publisher_mix_config.nim +++ b/examples/lightpush_publisher_mix_config.nim @@ -38,6 +38,12 @@ type name: "num-msgs", }: int + msgInterval*{. + desc: "Interval between messages in milliseconds.", + defaultValue: 1000, + name: "msg-interval", + }: int + minMixPoolSize* {. desc: "Number of messages to wait for before sending.", defaultValue: 3,