async def METHOD_NAME(self):
    if self._closed.is_set():  # pragma: no cover
        raise ChannelClosed("Channel already closed, cannot write message")
    try:
        return await self._in_queue.get()
    except RuntimeError:
        if self._closed.is_set():
            pass