mirror of
https://github.com/django/daphne.git
synced 2025-07-14 01:42:17 +03:00
Remove optional multiplexer arg in generics docs
This commit is contained in:
parent
9ae27cb835
commit
ef755e4c9d
|
@ -197,14 +197,14 @@ Example using class-based consumer::
|
||||||
from channels.generic.websockets import WebsocketDemultiplexer, JsonWebsocketConsumer
|
from channels.generic.websockets import WebsocketDemultiplexer, JsonWebsocketConsumer
|
||||||
|
|
||||||
class EchoConsumer(websockets.JsonWebsocketConsumer):
|
class EchoConsumer(websockets.JsonWebsocketConsumer):
|
||||||
def connect(self, message, multiplexer=None, **kwargs):
|
def connect(self, message, multiplexer, **kwargs):
|
||||||
# Send data with the multiplexer
|
# Send data with the multiplexer
|
||||||
multiplexer.send({"status": "I just connected!"})
|
multiplexer.send({"status": "I just connected!"})
|
||||||
|
|
||||||
def disconnect(self, message, multiplexer=None, **kwargs):
|
def disconnect(self, message, multiplexer, **kwargs):
|
||||||
print("Stream %s is closed" % multiplexer.stream)
|
print("Stream %s is closed" % multiplexer.stream)
|
||||||
|
|
||||||
def receive(self, content, multiplexer=None, **kwargs):
|
def receive(self, content, multiplexer, **kwargs):
|
||||||
# Simple echo
|
# Simple echo
|
||||||
multiplexer.send({"original_message": content})
|
multiplexer.send({"original_message": content})
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue
Block a user