You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
51 lines
1.5 KiB
51 lines
1.5 KiB
extern crate futures;
|
|
extern crate tokio_core;
|
|
extern crate tokio_tungstenite;
|
|
extern crate url;
|
|
|
|
use std::io;
|
|
|
|
use futures::{Future, Stream};
|
|
use tokio_core::net::{TcpStream, TcpListener};
|
|
use tokio_core::reactor::Core;
|
|
use tokio_tungstenite::{client_async, accept_async};
|
|
|
|
#[test]
|
|
fn handshakes() {
|
|
use std::sync::mpsc::channel;
|
|
use std::thread;
|
|
|
|
let (tx, rx) = channel();
|
|
|
|
thread::spawn(move || {
|
|
let mut core = Core::new().unwrap();
|
|
let handle = core.handle();
|
|
let address = "0.0.0.0:12345".parse().unwrap();
|
|
let listener = TcpListener::bind(&address, &handle).unwrap();
|
|
let connections = listener.incoming();
|
|
tx.send(()).unwrap();
|
|
let handshakes = connections.and_then(|(connection, _)| {
|
|
accept_async(connection).map_err(|e| io::Error::new(io::ErrorKind::Other, e))
|
|
});
|
|
let server = handshakes.for_each(|_| {
|
|
Ok(())
|
|
});
|
|
|
|
core.run(server).unwrap();
|
|
});
|
|
|
|
rx.recv().unwrap();
|
|
let mut core = Core::new().unwrap();
|
|
let handle = core.handle();
|
|
let address = "0.0.0.0:12345".parse().unwrap();
|
|
let tcp = TcpStream::connect(&address, &handle);
|
|
let handshake = tcp.and_then(|stream| {
|
|
let url = url::Url::parse("ws://localhost:12345/").unwrap();
|
|
client_async(url, stream).map_err(|e| io::Error::new(io::ErrorKind::Other, e))
|
|
});
|
|
let client = handshake.and_then(|_| {
|
|
Ok(())
|
|
});
|
|
core.run(client).unwrap();
|
|
}
|
|
|
|
|