actix/actix-extras
1
0
Fork 0
mirror of https://github.com/actix/actix-extras.git synced 2025-06-26 02:19:22 +02:00
Code Issues Releases Wiki Activity

modify unused_addr method; update websockt guide section

Browse Source
This commit is contained in:
Nikolay Kim
2017-12-26 20:52:21 -08:00
parent 3abd0db6b1
commit 183bcd38f8
4 changed files with 67 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/test.rs
View File

@ -11,6 +11,7 @@ use cookie::Cookie;
use http::{Uri, Method, Version, HeaderMap, HttpTryFrom};
use http::header::{HeaderName, HeaderValue};
use futures::Future;
use socket2::{Socket, Domain, Type};
use tokio_core::net::TcpListener;
use tokio_core::reactor::Core;
@ -137,7 +138,11 @@ impl TestServer {
/// Get firat available unused address
pub fn unused_addr() -> net::SocketAddr {
let tcp = net::TcpListener::bind("127.0.0.1:0").unwrap();
let addr: net::SocketAddr = "127.0.0.1:0".parse().unwrap();
let socket = Socket::new(Domain::ipv4(), Type::stream(), None).unwrap();
socket.bind(&addr.into()).unwrap();
socket.set_reuse_address(true).unwrap();
let tcp = socket.into_tcp_listener();
tcp.local_addr().unwrap()
}

30
src/ws.rs
View File

@ -6,28 +6,26 @@
//! ## Example
//!
//! ```rust
//! extern crate actix;
//! extern crate actix_web;
//!
//! # extern crate actix;
//! # extern crate actix_web;
//! use actix::*;
//! use actix_web::*;
//!
//! // do websocket handshake and start actor
//! fn ws_index(req: HttpRequest) -> Result<Reply> {
//! ws::start(req, WsRoute)
//! ws::start(req, Ws)
//! }
//!
//! // WebSocket Route
//! struct WsRoute;
//! struct Ws;
//!
//! impl Actor for WsRoute {
//! impl Actor for Ws {
//! type Context = HttpContext<Self>;
//! }
//!
//! // Define Handler for ws::Message message
//! impl StreamHandler<ws::Message> for WsRoute {}
//!
//! impl Handler<ws::Message> for WsRoute {
//! # impl StreamHandler<ws::Message> for Ws {}
//! #
//! impl Handler<ws::Message> for Ws {
//! fn handle(&mut self, msg: ws::Message, ctx: &mut HttpContext<Self>)
//! -> Response<Self, ws::Message>
//! {
@ -40,12 +38,12 @@
//! Self::empty()
//! }
//! }
//!
//! fn main() {
//! Application::new()
//! .resource("/ws/", |r| r.method(Method::GET).f(ws_index)) // <- register websocket route
//! .finish();
//! }
//! #
//! # fn main() {
//! # Application::new()
//! # .resource("/ws/", |r| r.f(ws_index)) // <- register websocket route
//! # .finish();
//! # }
//! ```
use std::vec::Vec;
use http::{Method, StatusCode, header};