def METHOD_NAME(self):
    """Clear state
    called after stop or when setting up a new subprocess
    """
    self._push = None
    self._push_mutex = None
    self.thread = None
    self.refs.clear()
    self.context = None