semaphore.MessageReceiver

class semaphore.MessageReceiver(socket: Socket, sender: MessageSender)[source]

Bases: object

This object represents a Signal message queue.

async receive() → AsyncIterable[Message][source]: Receive messages and return as Iterator.