Returns the next incoming message.

async def incoming(self):
        """Returns the next incoming message.
        """
        msg = await self._queue.get()
        self._queue.task_done()
        return msg