fix examples - disable signal if windows

examples/basic/src/main.rs

@@ -7,9 +7,9 @@ extern crate env_logger;
 extern crate futures;
 use futures::Stream;
 
+use actix::*;
 use actix_web::*;
-use actix::Arbiter;
+#[cfg(target_os = "linux")] use actix::actors::signal::{ProcessSignals, Subscribe};
-use actix::actors::signal::{ProcessSignals, Subscribe};
 use actix_web::middleware::RequestSession;
 use futures::future::{FutureResult, result};
 
@@ -96,9 +96,10 @@ fn main() {
         .bind("0.0.0.0:8080").unwrap()
         .start();
 
-    // Subscribe to unix signals
+    if cfg!(target_os = "linux") { // Subscribe to unix signals
         let signals = Arbiter::system_registry().get::<ProcessSignals>();
         signals.send(Subscribe(addr.subscriber()));
+    }
 
     println!("Starting http server: 127.0.0.1:8080");
     let _ = sys.run();

examples/json/src/main.rs

@@ -7,15 +7,14 @@ extern crate serde_json;
 #[macro_use] extern crate serde_derive;
 #[macro_use] extern crate json;
 
-
+use actix::*;
 use actix_web::*;
+#[cfg(target_os = "linux")] use actix::actors::signal::{ProcessSignals, Subscribe};
+
 use bytes::BytesMut;
 use futures::{Future, Stream};
 use json::JsonValue;
 
-use actix::Arbiter;
-use actix::actors::signal::{ProcessSignals, Subscribe};
-
 #[derive(Debug, Serialize, Deserialize)]
 struct MyObj {
     name: String,
@@ -97,8 +96,10 @@ fn main() {
         .shutdown_timeout(1)
         .start();
 
+    if cfg!(target_os = "linux") { // Subscribe to unix signals
         let signals = Arbiter::system_registry().get::<ProcessSignals>();
         signals.send(Subscribe(addr.subscriber()));
+    }
 
     println!("Started http server: 127.0.0.1:8080");
     let _ = sys.run();

examples/multipart/src/main.rs

@@ -6,11 +6,11 @@ extern crate futures;
 
 use actix::*;
 use actix_web::*;
+#[cfg(target_os = "linux")] use actix::actors::signal::{ProcessSignals, Subscribe};
+
 use futures::{Future, Stream};
 use futures::future::{result, Either};
 
-use actix::Arbiter;
-use actix::actors::signal::{ProcessSignals, Subscribe};
 
 fn index(mut req: HttpRequest) -> Box<Future<Item=HttpResponse, Error=Error>>
 {
@@ -55,8 +55,10 @@ fn main() {
         .bind("127.0.0.1:8080").unwrap()
         .start();
 
+    if cfg!(target_os = "linux") { // Subscribe to unix signals
         let signals = Arbiter::system_registry().get::<ProcessSignals>();
         signals.send(Subscribe(addr.subscriber()));
+    }
 
     println!("Starting http server: 127.0.0.1:8080");
     let _ = sys.run();

examples/signals/src/main.rs

@@ -5,7 +5,7 @@ extern crate env_logger;
 
 use actix::*;
 use actix_web::*;
-use actix::actors::signal::{ProcessSignals, Subscribe};
+#[cfg(target_os = "linux")] use actix::actors::signal::{ProcessSignals, Subscribe};
 
 struct MyWebSocket;
 
@@ -34,9 +34,10 @@ fn main() {
         .bind("127.0.0.1:8080").unwrap()
         .start();
 
-    // Subscribe to unix signals
+    if cfg!(target_os = "linux") { // Subscribe to unix signals
         let signals = Arbiter::system_registry().get::<ProcessSignals>();
         signals.send(Subscribe(addr.subscriber()));
+    }
 
     println!("Started http server: 127.0.0.1:8080");
     let _ = sys.run();

examples/template_tera/src/main.rs

@@ -3,9 +3,10 @@ extern crate actix_web;
 extern crate env_logger;
 #[macro_use]
 extern crate tera;
+
+use actix::*;
 use actix_web::*;
-use actix::Arbiter;
+#[cfg(target_os = "linux")] use actix::actors::signal::{ProcessSignals, Subscribe};
-use actix::actors::signal::{ProcessSignals, Subscribe};
 
 struct State {
     template: tera::Tera,  // <- store tera template in application state
@@ -42,9 +43,10 @@ fn main() {
         .bind("127.0.0.1:8080").unwrap()
         .start();
 
-    // Subscribe to unix signals
+    if cfg!(target_os = "linux") { // Subscribe to unix signals
         let signals = Arbiter::system_registry().get::<ProcessSignals>();
         signals.send(Subscribe(addr.subscriber()));
+    }
 
     println!("Started http server: 127.0.0.1:8080");
     let _ = sys.run();

examples/tls/src/main.rs

@@ -6,9 +6,9 @@ extern crate env_logger;
 use std::fs::File;
 use std::io::Read;
 
+use actix::*;
 use actix_web::*;
-use actix::Arbiter;
+#[cfg(target_os = "linux")] use actix::actors::signal::{ProcessSignals, Subscribe};
-use actix::actors::signal::{ProcessSignals, Subscribe};
 
 /// somple handle
 fn index(req: HttpRequest) -> Result<HttpResponse> {
@@ -47,9 +47,10 @@ fn main() {
         .bind("127.0.0.1:8443").unwrap()
         .start_ssl(&pkcs12).unwrap();
 
-    // Subscribe to unix signals
+    if cfg!(target_os = "linux") { // Subscribe to unix signals
         let signals = Arbiter::system_registry().get::<ProcessSignals>();
         signals.send(Subscribe(addr.subscriber()));
+    }
 
     println!("Started http server: 127.0.0.1:8443");
     let _ = sys.run();

examples/websocket-chat/src/main.rs

@@ -17,8 +17,7 @@ use std::time::Instant;
 
 use actix::*;
 use actix_web::*;
-use actix::Arbiter;
+#[cfg(target_os = "linux")] use actix::actors::signal::{ProcessSignals, Subscribe};
-use actix::actors::signal::{ProcessSignals, Subscribe};
 
 mod codec;
 mod server;
@@ -216,9 +215,10 @@ fn main() {
         .bind("127.0.0.1:8080").unwrap()
         .start();
 
-    // Subscribe to unix signals
+    if cfg!(target_os = "linux") { // Subscribe to unix signals
         let signals = Arbiter::system_registry().get::<ProcessSignals>();
         signals.send(Subscribe(addr.subscriber()));
+    }
 
     println!("Started http server: 127.0.0.1:8080");
     let _ = sys.run();