wurl 0.1.0

WebSocket CLI for developers
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

use std::result::Result;
use std::thread;
use util::options::Options;
use url::Url;
use network::handler::Client;
use ws::{Error as WsError, ErrorKind, Sender, WebSocket};

pub fn connect(options: Options) -> Result<Sender, WsError> {
    let url = options.url.clone();
    trace!("Parsed URL as {:?}", url);
    let mut ws = WebSocket::new(move |out| Client {
        out: out,
        options: options.clone(),
    })?;
    let parsed = Url::parse(&url).map_err(|err| {
        WsError::new(
            ErrorKind::Internal,
            format!("Unable to parse {} as url due to {:?}", &url, err),
        )
    })?;

    debug!("About to connect to {}", parsed);
    ws.connect(parsed)?;
    let sender = ws.broadcaster();

    thread::Builder::new()
        .name("websocket_handler".to_owned())
        .spawn(move || {
            // This blocks the thread
            ws.run()
        })
        .expect("Failed to start WebSocket thread");

    Ok(sender)
}