Advertisement
Guest User

Untitled

a guest
Mar 18th, 2019
69
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 0.47 KB | None | 0 0
  1. pub fn main(
  2. receiver: mpsc::Receiver<PositionMessage>,
  3. sender: mpsc::Sender<Input>
  4. ) {
  5. let receiver = Arc::new(Mutex::new(receiver));
  6.  
  7. listen("0.0.0.0:8081", |out| {
  8. let receiver = receiver.clone();
  9. let out_clone = out.clone();
  10.  
  11. thread::spawn(move || {
  12. loop {
  13. let message = receiver.lock().unwrap().recv().unwrap();
  14. out_clone.send(json::to_string(&message).unwrap()).unwrap();
  15. }
  16. });
  17.  
  18. Server { out: out }
  19. }).unwrap()
  20. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement