worker.rs

		});

		handle.sender.unbounded_send(listen_msg_1).unwrap();
		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));
	}
}