async def messages(self):
    if not self._is_subscribe:
        raise ValueError('You must subscribe to the topic first')
    while self._is_subscribe:
        yield await self._queue.get()

de51e5a337fe11b24fc78a160e11b33dbe5a0268
<mask token>

async def messages(self):
    if not self._is_subscribe:
        raise ValueError('You must subscribe to the topic first')
    while self._is_subscribe:
        yield await self._queue.get()
