AsyncPubSubClient

Bases: Subscribe

Asynchronous Redis Publish/Subscribe Client.

Supports channel subscription, unsubscription, pattern-based subscriptions, and listening for incoming messages asynchronously.

Source code in pyredis/client/async_pubsub.py

class AsyncPubSubClient(commands.Subscribe):
    """
    Asynchronous Redis Publish/Subscribe Client.

    Supports channel subscription, unsubscription, pattern-based subscriptions,
    and listening for incoming messages asynchronously.
    """

    def __init__(self, **kwargs):
        """
        Initialize the AsyncPubSubClient connection.

        Args:
            **kwargs: Connection options forwarded to AsyncConnection.
        """
        self._conn = pyredis.client.AsyncConnection(**kwargs)

    async def close(self):
        """Close the underlying connection asynchronously."""
        await self._conn.close()

    @property
    def closed(self):
        """Flag indicating if the connection is closed."""
        return self._conn.closed

    async def write(self, *args):
        """
        Write a command to the underlying connection asynchronously.

        Args:
            *args: Command name and arguments.
        """
        return await self._conn.write(*args)

    async def get(self):
        """
        Read the next message/response from the connection asynchronously.

        Returns:
            The message or response read from Redis.
        """
        return await self._conn.read(close_on_timeout=False)

closed property

Flag indicating if the connection is closed.

__init__(**kwargs)

Initialize the AsyncPubSubClient connection.

Parameters:

Name	Type	Description	Default
**kwargs		Connection options forwarded to AsyncConnection.	{}

Source code in pyredis/client/async_pubsub.py

def __init__(self, **kwargs):
    """
    Initialize the AsyncPubSubClient connection.

    Args:
        **kwargs: Connection options forwarded to AsyncConnection.
    """
    self._conn = pyredis.client.AsyncConnection(**kwargs)

close() async

Close the underlying connection asynchronously.

Source code in pyredis/client/async_pubsub.py

async def close(self):
    """Close the underlying connection asynchronously."""
    await self._conn.close()

get() async

Read the next message/response from the connection asynchronously.

Returns:

Type	Description
	The message or response read from Redis.

Source code in pyredis/client/async_pubsub.py

async def get(self):
    """
    Read the next message/response from the connection asynchronously.

    Returns:
        The message or response read from Redis.
    """
    return await self._conn.read(close_on_timeout=False)

psubscribe(*args)

Source code in pyredis/commands/subscribe.py

def psubscribe(self, *args):
    return self.write(
        *[b"PSUBSCRIBE", *args]
    )

punsubscribe(*args)

Source code in pyredis/commands/subscribe.py

def punsubscribe(self, *args):
    return self.write(
        *[b"PUNSUBSCRIBE", *args]
    )

subscribe(*args)

Source code in pyredis/commands/subscribe.py

def subscribe(self, *args):
    return self.write(
        *[b"SUBSCRIBE", *args]
    )

unsubscribe(*args)

Source code in pyredis/commands/subscribe.py

def unsubscribe(self, *args):
    return self.write(
        *[b"UNSUBSCRIBE", *args]
    )

write(*args) async

Write a command to the underlying connection asynchronously.

Parameters:

Name	Type	Description	Default
*args		Command name and arguments.	()

Source code in pyredis/client/async_pubsub.py

async def write(self, *args):
    """
    Write a command to the underlying connection asynchronously.

    Args:
        *args: Command name and arguments.
    """
    return await self._conn.write(*args)