channelsmultiplexer 0.0.3

Version Compatibility

Install

pip install channelsmultiplexer

Usage

to create a De-Multiplexer

class EchoDemultiplexerAsyncJson(AsyncJsonWebsocketDemultiplexer):
    applications = {
        "echostream": EchoTestConsumer(),
        "altechostream": AltEchoTestConsumer(),
        "closeafterfirst": EchoCloseAfterFirstTestConsumer(),
        "neveraccept": NeverAcceptTestConsumer()
    }

or you can use the AsyncJsonWebsocketDemultiplexer type directly and pass the multiplexed upstream consumers as kwargs.

application = ProtocolTypeRouter({
                      "websocket": URLRouter([
                                      url(r"^ws/$", AsyncJsonWebsocketDemultiplexer(
                                              echostream = EchoTestConsumer(),
                                              altechostream = AltEchoTestConsumer(),
                                              closeafterfirst = EchoCloseAfterFirstTestConsumer(),
                                              neveraccept = NeverAcceptTestConsumer()
                                      )),
                      ]),
                      "telegram": ChattyBotConsumer.as_asgi(),
      })

This acts just as any other channels consumer, however it will route incoming (JSON) messages to the upstream Consumers.

It does this by reading the value of the stream attribute in the message body. It will then pass the value of the payload attribute upstream.

{
    "stream": "echostream",
    "payload": {"hello": "world"}
}

Messages being sent downstream from the Multiplexed consumers will be embedded within a similar style msg.