Lines Matching refs:unwrap

26     let rt = Arc::new(Runtime::new().unwrap());  in main()
52     let root_server_port = value_t!(matches, "root-server-port", u16).unwrap();  in async_main()
53     let grpc_port = value_t!(matches, "grpc-port", u16).unwrap();  in async_main()
54     let signal_port = value_t!(matches, "signal-port", u16).unwrap();  in async_main()
66         .unwrap();  in async_main()
71     block_on(server.shutdown()).unwrap();  in async_main()
76     let mut stream = TcpStream::connect(address).await.unwrap();  in indicate_started()
77     stream.shutdown().await.unwrap();  in indicate_started()
83     *SIGINT_TX.lock().unwrap() = Some(tx);  in install_sigint()
91         signal::sigaction(signal::SIGINT, &sig_action).unwrap();  in install_sigint()
102     let mut sigint_tx = SIGINT_TX.lock().unwrap();  in handle_sigint()
105         tx.unbounded_send(()).unwrap();  in handle_sigint()