Import private actix as actix_inner

src/client/connector.rs

@@ -1,12 +1,14 @@
+extern crate actix;
+
 use std::collections::{HashMap, VecDeque};
 use std::net::Shutdown;
 use std::time::{Duration, Instant};
 use std::{fmt, io, mem, time};
 
-use actix::actors::{Connect as ResolveConnect, Connector, ConnectorError};
+use self::actix::actors::{Connect as ResolveConnect, Connector, ConnectorError};
-use actix::fut::WrapFuture;
+use self::actix::fut::WrapFuture;
-use actix::registry::SystemService;
+use self::actix::registry::SystemService;
-use actix::{
+use self::actix::{
     fut, Actor, ActorFuture, ActorResponse, AsyncContext, Context, ContextFutureSpawner,
     Handler, Message, Recipient, StreamHandler, Supervised,
 };

src/client/pipeline.rs

@@ -1,3 +1,5 @@
+extern crate actix;
+
 use bytes::{Bytes, BytesMut};
 use futures::sync::oneshot;
 use futures::{Async, Future, Poll};
@@ -6,7 +8,7 @@ use std::time::{Duration, Instant};
 use std::{io, mem};
 use tokio_timer::Delay;
 
-use actix::prelude::*;
+use self::actix::prelude::*;
 
 use super::{
     ClientBody, ClientBodyStream, ClientConnector, ClientConnectorError, ClientRequest,

src/context.rs

@@ -1,12 +1,14 @@
+extern crate actix;
+
 use futures::sync::oneshot;
 use futures::sync::oneshot::Sender;
 use futures::{Async, Future, Poll};
 use smallvec::SmallVec;
 use std::marker::PhantomData;
 
-use actix::dev::{ContextImpl, Envelope, ToEnvelope};
+use self::actix::dev::{ContextImpl, Envelope, ToEnvelope};
-use actix::fut::ActorFuture;
+use self::actix::fut::ActorFuture;
-use actix::{
+use self::actix::{
     Actor, ActorContext, ActorState, Addr, AsyncContext, Handler, Message, SpawnHandle,
 };
 

src/httpmessage.rs

@@ -224,12 +224,13 @@ pub trait HttpMessage {
     /// ## Server example
     ///
     /// ```rust
+    /// # extern crate actix;
     /// # extern crate actix_web;
     /// # extern crate env_logger;
     /// # extern crate futures;
     /// # use std::str;
     /// # use actix_web::*;
-    /// # use actix_web::actix::*;
+    /// # use actix::*;
     /// # use futures::{Future, Stream};
     /// # use futures::future::{ok, result, Either};
     /// fn index(mut req: HttpRequest) -> Box<Future<Item=HttpResponse, Error=Error>> {

src/lib.rs

@@ -132,7 +132,7 @@ extern crate serde_json;
 extern crate serde_urlencoded;
 extern crate smallvec;
 #[macro_use]
-extern crate actix;
+pub extern crate actix as actix_inner;
 
 #[cfg(test)]
 #[macro_use]
@@ -194,8 +194,11 @@ pub use httprequest::HttpRequest;
 pub use httpresponse::HttpResponse;
 pub use json::Json;
 pub use scope::Scope;
+
 pub mod actix {
-    use super::actix::prelude::*;
+    //! Re-exports [actix's](https://docs.rs/actix) prelude
+
+    pub use actix_inner::prelude::*;
 }
 
 #[doc(hidden)]

src/server/mod.rs

@@ -1,8 +1,9 @@
 //! Http server
+extern crate actix;
+
 use std::net::Shutdown;
 use std::{io, time};
 
-use actix;
 use bytes::BytesMut;
 use futures::{Async, Poll};
 use tokio_io::{AsyncRead, AsyncWrite};

src/server/srv.rs

@@ -1,10 +1,12 @@
+extern crate actix;
+
 use std::rc::Rc;
 use std::sync::{mpsc as sync_mpsc, Arc};
 use std::time::Duration;
 use std::{io, net, thread};
 
-use actix::actors::signal;
+use self::actix::actors::signal;
-use actix::prelude::*;
+use self::actix::prelude::*;
 use futures::sync::mpsc;
 use futures::{Future, Sink, Stream};
 use mio;
@@ -19,7 +21,7 @@ use native_tls::TlsAcceptor;
 #[cfg(feature = "alpn")]
 use openssl::ssl::{AlpnError, SslAcceptorBuilder};
 
-use super::channel::{HttpChannel, WrapperStream};
+use super::channel::{WrapperStream};
 use super::settings::{ServerSettings, WorkerSettings};
 use super::worker::{Conn, SocketInfo, StopWorker, StreamHandlerType, Worker};
 use super::{IntoHttpHandler, IoStream, KeepAlive};
@@ -406,7 +408,8 @@ impl<H: IntoHttpHandler> HttpServer<H> {
     ///
     /// ```rust
     /// extern crate actix_web;
-    /// use actix_web::{actix, server, App, HttpResponse};
+    /// extern crate actix;
+    /// use actix_web::{server, App, HttpResponse};
     ///
     /// fn main() {
     ///     // Run actix system, this method actually starts all async processes

src/server/worker.rs

@@ -1,3 +1,5 @@
+extern crate actix;
+
 use futures::sync::oneshot;
 use futures::Future;
 use net2::TcpStreamExt;
@@ -21,8 +23,8 @@ use openssl::ssl::SslAcceptor;
 #[cfg(feature = "alpn")]
 use tokio_openssl::SslAcceptorExt;
 
-use actix::msgs::StopArbiter;
+use self::actix::msgs::StopArbiter;
-use actix::*;
+use self::actix::*;
 
 use server::channel::HttpChannel;
 use server::settings::WorkerSettings;

src/test.rs

@@ -1,11 +1,13 @@
 //! Various helpers for Actix applications to use during testing.
 
+extern crate actix;
+
 use std::rc::Rc;
 use std::str::FromStr;
 use std::sync::mpsc;
 use std::{net, thread};
 
-use actix::{msgs, Actor, Addr, Arbiter, System};
+use self::actix::{msgs, Actor, Addr, Arbiter, System};
 use cookie::Cookie;
 use futures::Future;
 use http::header::HeaderName;

src/ws/client.rs

@@ -1,4 +1,6 @@
 //! Http client request
+extern crate actix;
+
 use std::cell::UnsafeCell;
 use std::rc::Rc;
 use std::time::Duration;
@@ -14,7 +16,7 @@ use http::{Error as HttpError, HttpTryFrom, StatusCode};
 use rand;
 use sha1::Sha1;
 
-use actix::prelude::*;
+use self::actix::prelude::*;
 
 use body::Binary;
 use error::{Error, UrlParseError};

src/ws/context.rs

@@ -1,10 +1,12 @@
+extern crate actix;
+
 use futures::sync::oneshot::{self, Sender};
 use futures::{Async, Poll};
 use smallvec::SmallVec;
 
-use actix::dev::{ContextImpl, Envelope, ToEnvelope};
+use self::actix::dev::{ContextImpl, Envelope, ToEnvelope};
-use actix::fut::ActorFuture;
+use self::actix::fut::ActorFuture;
-use actix::{
+use self::actix::{
     Actor, ActorContext, ActorState, Addr, AsyncContext, Handler, Message, SpawnHandle,
 };
 

src/ws/mod.rs

@@ -42,11 +42,13 @@
 //! #      .finish();
 //! # }
 //! ```
+extern crate actix;
+
 use bytes::Bytes;
 use futures::{Async, Poll, Stream};
 use http::{header, Method, StatusCode};
 
-use actix::{Actor, AsyncContext, StreamHandler};
+use self::actix::{Actor, AsyncContext, StreamHandler};
 
 use body::Binary;
 use error::{Error, PayloadError, ResponseError};