ChannelsConsumer

Base channels async consumer.

Constructor:

Signature:

def __init__(self, args: str = (), kwargs: Any = {}) -> None:
...

Parameters:

  1. args:

    Type
    str
    Default
    ()
  2. kwargs:

    Type
    Any
    Default
    {}

Methods:

Attributes:

  1. channel_name:

    Type
    str
  2. channel_layer:

    Type
    ChannelsLayer | None
  3. channel_receive:

    Type
    Callable[[], Awaitable[dict]]
  4. listen_queues:

    Type
    DefaultDict[str, WeakSet[asyncio.Queue]]