music_queue¶

Module Contents¶

Classes¶

Functions¶

Attributes¶

class music_queue.__RemoteMusicQueue(server_id: str, queue_size: int)¶

Bases: pipo.player.queue.PlayerQueue

Remote music queue.

__broker¶

Controls connection to remote queues.

Type:¶

faststream.rabbit.RabbitBroker

server_id : str¶

__playable_music : asyncio.Queue[str]¶

__publisher : faststream.rabbit.RabbitPublisher¶

__requests : Dict[str, int]¶

static __generate_uuid() → str¶

async add(query: str | Iterable[str], shuffle: bool = False) → None¶

async _add_music(request: pipo.player.music_queue.models.music.Music)¶

async get(timeout: int = 0) → str | None¶

size() → int¶

Music to be played.

Sum of enqueued music.

Returns:¶

Queue size.

Return type:¶

int

clear() → None¶

Clear queue.

music_queue.music_queue¶

async music_queue.consume_music(request: pipo.player.music_queue.models.music.Music, logger: faststream.Logger) → None¶