mockservice: def __init__(self): self.msgs = ["woo", "moo", NetworkError] def GetMessage(): return self.msgs.pop() for i in ["woo", "moo", NetworkError]: client["chan|newmessage"].Listen() channel.emit("newmessage") client["chan|newmessage"].Wait() msg = client["chan"].GetMessage() assert msg == i