Add example

Cargo.toml

@@ -64,6 +64,9 @@ required-features = ["compress"]
 name = "test_server"
 required-features = ["compress"]
 
+[[example]]
+name = "on_connect"
+
 [dependencies]
 actix-codec = "0.3.0"
 actix-service = "1.0.6"

examples/on_connect.rs

@@ -0,0 +1,31 @@
+//! This example shows how to use `actix_web::HttpServer::on_connect`
+
+#[derive(Clone)]
+struct ConnectionInfo(String);
+
+async fn route_whoami(req: actix_web::HttpRequest) -> String {
+    let extensions = req.extensions();
+    let conn_info = extensions.get::<ConnectionInfo>().unwrap();
+    format!("Here is some info about you: {}", conn_info.0)
+}
+
+fn on_connect(connection: &dyn std::any::Any) -> ConnectionInfo {
+    let sock = connection.downcast_ref::<actix_rt::net::TcpStream>().unwrap();
+    let msg = format!("local_addr={:?}\npeer_addr={:?}", sock.local_addr(),sock.peer_addr());
+    ConnectionInfo(msg)
+}
+
+#[actix_rt::main]
+async fn main() -> std::io::Result<()> {
+    std::env::set_var("RUST_LOG", "actix_server=info,actix_web=info");
+    env_logger::init();
+
+    actix_web::HttpServer::new(|| {
+        actix_web::App::new().route("/", actix_web::web::get().to(route_whoami))
+    })
+    .on_connect(std::sync::Arc::new(on_connect))
+    .bind("127.0.0.1:8080")?
+    .workers(1)
+    .run()
+    .await
+}

src/server.rs

@@ -102,6 +102,7 @@ where
     /// - `actix_tls::openssl::SslStream<tokio::net::TcpStream>` when using openssl.
     /// - `actix_tls::rustls::TlsStream<tokio::net::TcpStream>` when using rustls.
     /// - `tokio::net::TcpStream` when no encryption is used.
+    /// See `on_connect` example for additional details.
     pub fn on_connect<C>(
         self,
         f: Arc<dyn Fn(&dyn std::any::Any) -> C + Send + Sync>,