def unsubscribe(cls, username): cls._zmq_stream.socket.setsockopt(zmq.UNSUBSCRIBE, username.encode('utf-8'))