actix/actix-extras
1
0
Fork 0
mirror of https://github.com/actix/actix-extras.git synced 2024-11-24 16:02:59 +01:00
Code Issues Releases Wiki Activity

Keep running unconnected actor forever if backoff says so

Browse Source
This commit is contained in:
Tobias Bieniek 2018-05-27 09:55:41 +02:00
parent 3bbda68adf
commit 6624af63e3
1 changed files with 0 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/redis.rs
View File

@ -77,8 +77,6 @@ impl Actor for RedisActor {
// we stop current context, supervisor will restart it. // we stop current context, supervisor will restart it.
if let Some(timeout) = act.backoff.next_backoff() { if let Some(timeout) = act.backoff.next_backoff() {
ctx.run_later(timeout, |_, ctx| ctx.stop()); ctx.run_later(timeout, |_, ctx| ctx.stop());
} else {
ctx.stop();
} }
} }
}) })
@ -88,8 +86,6 @@ impl Actor for RedisActor {
// we stop current context, supervisor will restart it. // we stop current context, supervisor will restart it.
if let Some(timeout) = act.backoff.next_backoff() { if let Some(timeout) = act.backoff.next_backoff() {
ctx.run_later(timeout, |_, ctx| ctx.stop()); ctx.run_later(timeout, |_, ctx| ctx.stop());
} else {
ctx.stop();
} }
}) })
.wait(ctx); .wait(ctx);