()
| 112 | } |
| 113 | |
| 114 | fn main() { |
| 115 | let server = WebSocket::new(|out| Server { |
| 116 | out: out, |
| 117 | ping_timeout: None, |
| 118 | client_unresponsive_timeout: None, |
| 119 | }) |
| 120 | .unwrap(); |
| 121 | let broadcaster = server.broadcaster(); |
| 122 | |
| 123 | let periodic = thread::spawn(move || loop { |
| 124 | broadcaster.send("Meow").unwrap(); |
| 125 | thread::sleep(time::Duration::from_secs(1)); |
| 126 | }); |
| 127 | server.listen("127.0.0.1:8080").unwrap(); |
| 128 | periodic.join().unwrap(); |
| 129 | } |
nothing calls this directly
no outgoing calls
no test coverage detected