Newer
Older
runtime.block_on(r1.unit_error().boxed().compat()).unwrap().unwrap().unwrap();
// The gossip sender taken => listener registered.
assert!(!messages.messages.lock().unwrap().contains_key(&topic_1));
}
}
runtime.block_on(r1.unit_error().boxed().compat()).unwrap().unwrap().unwrap();
// The gossip sender taken => listener registered.
assert!(!messages.messages.lock().unwrap().contains_key(&topic_1));
}
}