actix/actix-extras
1
0
Fork 0
mirror of https://github.com/actix/actix-extras.git synced 2024-11-28 01:32:57 +01:00
Code Issues Releases Wiki Activity

fix handling ServerCommand #316

Browse Source
This commit is contained in:
Nikolay Kim 2018-06-16 22:56:27 +06:00
parent 566b16c1f7
commit 342a194605
1 changed files with 3 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/server/srv.rs
View File

@ -4,7 +4,7 @@ use std::time::Duration;
use std::{io, net, thread}; use std::{io, net, thread};
use actix::{ use actix::{
fut, signal, Actor, ActorContext, ActorFuture, Addr, Arbiter, AsyncContext, Context, fut, signal, Actor, ActorFuture, Addr, Arbiter, AsyncContext, Context,
ContextFutureSpawner, Handler, Response, StreamHandler, System, WrapFuture, ContextFutureSpawner, Handler, Response, StreamHandler, System, WrapFuture,
}; };
@ -617,9 +617,7 @@ impl<H: IntoHttpHandler> Handler<signal::Signal> for HttpServer<H> {
/// Commands from accept threads /// Commands from accept threads
impl<H: IntoHttpHandler> StreamHandler<ServerCommand, ()> for HttpServer<H> { impl<H: IntoHttpHandler> StreamHandler<ServerCommand, ()> for HttpServer<H> {
fn handle( fn handle(&mut self, msg: Result<Option<ServerCommand>, ()>, _: &mut Context<Self>) {
&mut self, msg: Result<Option<ServerCommand>, ()>, ctx: &mut Context<Self>,
) {
match msg { match msg {
Ok(Some(ServerCommand::WorkerDied(idx, socks))) => { Ok(Some(ServerCommand::WorkerDied(idx, socks))) => {
let mut found = false; let mut found = false;
@ -667,7 +665,7 @@ impl<H: IntoHttpHandler> StreamHandler<ServerCommand, ()> for HttpServer<H> {
self.workers.push((new_idx, addr)); self.workers.push((new_idx, addr));
} }
} }
_ => ctx.stop(), _ => (),
} }
} }
} }