We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 86ecbaf commit cae99c6Copy full SHA for cae99c6
1 file changed
nats-server/src/lib.rs
@@ -367,7 +367,7 @@ mod tests {
367
let jetstream = async_nats::jetstream::new(client);
368
369
let retry_strategy = tokio_retry::strategy::ExponentialBackoff::from_millis(500).take(3);
370
- let mut stream = tokio_retry::Retry::spawn(retry_strategy, || {
+ let mut stream = tokio_retry::Retry::start(retry_strategy, || {
371
jetstream.create_stream(async_nats::jetstream::stream::Config {
372
name: "replicated".to_string(),
373
num_replicas: 3,
0 commit comments