def METHOD_NAME(self, sock, _addr):
    """Serve events."""
    with self.lock.acquire_nonblock() as result:
        if not result:
            self.logger.info("multiple event clients not supported")
        else:
            self.logger.info("event client connected")
            while True:
                event = self.event_q.get()
                event_bytes = bytes(
                    "\n".join((json.dumps(event, default=str), "")).encode("UTF-8")
                )
                try:
                    sock.sendall(event_bytes)
                except (socket.error, IOError) as err:
                    self.logger.info("event client disconnected: %s", err)
                    break
    try:
        sock.close()
    except (socket.error, IOError):
        pass