def header(self): flags = 0 if self.block else zmq.NOBLOCK self.raw_header = self.socket.recv(flags=flags) return json.loads(self.raw_header.decode("utf-8"))