async def METHOD_NAME(self, message: Any):
    if self._closed.is_set():  # pragma: no cover
        raise ChannelClosed("Channel already closed, cannot send message")
    # put message directly into queue
    self._out_queue.put_nowait(message)