This commit is contained in:
NikVolf 2016-04-04 01:52:19 +03:00
parent fa63d9e34a
commit 35465debd6

View File

@ -148,7 +148,7 @@ mod tests {
#[test] #[test]
fn can_add_duplex_socket_to_worker() { fn can_add_duplex_socket_to_worker() {
let mut worker = Worker::<DummyService>::new(Arc::new(DummyService::new())); let mut worker = Worker::<DummyService>::new(Arc::new(DummyService::new()));
worker.add_duplex("ipc://tmp/parity-test10.ipc").unwrap(); worker.add_duplex("ipc:///tmp/parity-test10.ipc").unwrap();
assert_eq!(1, worker.sockets.len()); assert_eq!(1, worker.sockets.len());
} }
@ -156,7 +156,7 @@ mod tests {
fn worker_can_poll_empty() { fn worker_can_poll_empty() {
let service = Arc::new(DummyService::new()); let service = Arc::new(DummyService::new());
let mut worker = Worker::<DummyService>::new(service.clone()); let mut worker = Worker::<DummyService>::new(service.clone());
worker.add_duplex("ipc://tmp/parity-test20.ipc").unwrap(); worker.add_duplex("ipc:///tmp/parity-test20.ipc").unwrap();
worker.poll(); worker.poll();
assert_eq!(0, service.methods_stack.read().unwrap().len()); assert_eq!(0, service.methods_stack.read().unwrap().len());
} }