mirror of https://github.com/fafhrd91/actix-net
tweaks
This commit is contained in:
parent
a1982bdbad
commit
a868ce9be5
|
@ -20,7 +20,7 @@ default = ["http"]
|
||||||
[dependencies]
|
[dependencies]
|
||||||
regex = "1.3.1"
|
regex = "1.3.1"
|
||||||
serde = "1.0.104"
|
serde = "1.0.104"
|
||||||
bytestring = "0.1.2"
|
bytestring = ">=0.1.5, <2"
|
||||||
log = "0.4.8"
|
log = "0.4.8"
|
||||||
http = { version = "0.2.2", optional = true }
|
http = { version = "0.2.2", optional = true }
|
||||||
|
|
||||||
|
|
|
@ -252,11 +252,6 @@ impl ServerBuilder {
|
||||||
Ok(self)
|
Ok(self)
|
||||||
}
|
}
|
||||||
|
|
||||||
#[doc(hidden)]
|
|
||||||
pub fn start(self) -> Server {
|
|
||||||
self.run()
|
|
||||||
}
|
|
||||||
|
|
||||||
/// Starts processing incoming connections and return server controller.
|
/// Starts processing incoming connections and return server controller.
|
||||||
pub fn run(mut self) -> Server {
|
pub fn run(mut self) -> Server {
|
||||||
if self.sockets.is_empty() {
|
if self.sockets.is_empty() {
|
||||||
|
|
|
@ -49,10 +49,7 @@ impl TestServer {
|
||||||
// run server in separate thread
|
// run server in separate thread
|
||||||
thread::spawn(move || {
|
thread::spawn(move || {
|
||||||
let sys = System::new("actix-test-server");
|
let sys = System::new("actix-test-server");
|
||||||
factory(Server::build())
|
factory(Server::build()).workers(1).disable_signals().run();
|
||||||
.workers(1)
|
|
||||||
.disable_signals()
|
|
||||||
.start();
|
|
||||||
|
|
||||||
tx.send(System::current()).unwrap();
|
tx.send(System::current()).unwrap();
|
||||||
sys.run()
|
sys.run()
|
||||||
|
@ -83,7 +80,7 @@ impl TestServer {
|
||||||
.unwrap()
|
.unwrap()
|
||||||
.workers(1)
|
.workers(1)
|
||||||
.disable_signals()
|
.disable_signals()
|
||||||
.start();
|
.run();
|
||||||
tx.send((System::current(), local_addr)).unwrap();
|
tx.send((System::current(), local_addr)).unwrap();
|
||||||
});
|
});
|
||||||
sys.run()
|
sys.run()
|
||||||
|
|
|
@ -327,7 +327,9 @@ macro_rules! forward_ready {
|
||||||
&mut self,
|
&mut self,
|
||||||
cx: &mut ::core::task::Context<'_>,
|
cx: &mut ::core::task::Context<'_>,
|
||||||
) -> ::core::task::Poll<Result<(), Self::Error>> {
|
) -> ::core::task::Poll<Result<(), Self::Error>> {
|
||||||
self.$field.poll_ready(cx)
|
self.$field
|
||||||
|
.poll_ready(cx)
|
||||||
|
.map_err(::core::convert::Into::into)
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue