+ Store::new(path).and_then(move |store| {
+ unsafe { DATA_STORE = Some(Box::new(store)) };
+ let store = unsafe { DATA_STORE.as_ref().unwrap() };
+ unsafe { PRINTER = Some(Box::new(Printer::new(store))) };
+
+ let trusted_sockaddr: SocketAddr = addr.parse().unwrap();
+ make_trusted_conn(trusted_sockaddr);
+
+ reader::read(store, unsafe { PRINTER.as_ref().unwrap() });
+
+ future::ok(())
+ }).or_else(|_| {
+ future::err(())
+ })
+ }));
+
+ tokio::run(future::lazy(|| {
+ unsafe { DATA_STORE.as_ref().unwrap() }.save_data()