From 6af2f5d6429e6855d20fdc5bfe8195850e4b50b1 Mon Sep 17 00:00:00 2001 From: Nikolay Kim Date: Thu, 5 Jul 2018 12:14:10 +0600 Subject: [PATCH] re-enable start_incoming support --- src/server/srv.rs | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/src/server/srv.rs b/src/server/srv.rs index dc7321213..8582ab1f8 100644 --- a/src/server/srv.rs +++ b/src/server/srv.rs @@ -22,7 +22,7 @@ use native_tls::TlsAcceptor; #[cfg(feature = "alpn")] use openssl::ssl::{AlpnError, SslAcceptorBuilder}; -use super::channel::WrapperStream; +use super::channel::{HttpChannel, WrapperStream}; use super::settings::{ServerSettings, WorkerSettings}; use super::worker::{Conn, SocketInfo, StopWorker, StreamHandlerType, Worker}; use super::{IntoHttpHandler, IoStream, KeepAlive}; @@ -674,14 +674,13 @@ where { type Result = (); - fn handle(&mut self, _msg: Conn, _: &mut Context) -> Self::Result { - unimplemented!(); - /*Arbiter::spawn(HttpChannel::new( + fn handle(&mut self, msg: Conn, _: &mut Context) -> Self::Result { + Arbiter::spawn(HttpChannel::new( Rc::clone(self.h.as_ref().unwrap()), msg.io, msg.peer, msg.http2, - ));*/ + )); } }