def METHOD_NAME(self, level: ServiceLevel, pub: Published):
    if level is ServiceLevel.MAY_DROP:
        stream = self._may_drop.METHOD_NAME
    elif level is ServiceLevel.MUST_DELIVER:
        stream = self._must_deliver.METHOD_NAME
    else:
        raise ValueError(f"Unknown service level {level}")  # pragma: no cover
    try:
        stream.send_nowait(pub)
    except WouldBlock:
        pass