Usage

WebsocketDemultiplexer classes expect a class-level attribute consumer_classes that contains a mapping between stream and consumer.

class Demultiplexer(WebsocketDemultiplexer):
    # Wire your async JSON consumers here: {stream_name: consumer}
    consumer_classes = {
        "echo": EchoConsumer,
        "other": AnotherConsumer,
    }