code: def recv(self) -> Any:
      obj = self._sub_socket.recv_pyobj()
  
      if not isinstance(obj, _SerialMessage):
          raise RuntimeError(
              f"non-_SerialMessage: {type(obj).__name__}"
          )
  
      if obj.serial != self._recv_serial:
          raise RuntimeError(
              f"Out-of-order server message detected: {obj.serial} != {self._recv_serial}"
          )
  
      self._recv_serial += 1
      return obj.payload
  
imports: import logging
  import os
  import selectors
  import signal
  import socket
  import subprocess
  import time
  from typing import Any, Callable, Dict, List, Optional, Tuple, Union
  import determined
label_desc: Use image node_id 7 for calling the ZMQBroadcastClient obj's underlying member method code with example usage: obj.recv() and returns: obj