def METHOD_NAME(self):
    """Return the next message published on the Socket.IO channel,
    blocking until a message is available.
    This method needs to be implemented by the different subclasses that
    support pub/sub backends.
    """
    raise NotImplementedError('This method must be implemented in a '
                              'subclass.')  # pragma: no cover