django/daphne
1
1
Fork 0
mirror of https://github.com/django/daphne.git synced 2025-07-13 09:22:17 +03:00
Code Issues Packages Projects Releases Wiki Activity

Remove last vestige of Channel.consumer

Browse Source
This commit is contained in:
Andrew Godwin 2015-07-13 23:42:45 -07:00
parent edd4999384
commit 3c001716b7
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
docs/concepts.rst
View File

@ -62,7 +62,9 @@ How do we use channels?
That's what a channel is, but how is Django using them? Well, inside Django That's what a channel is, but how is Django using them? Well, inside Django
you can connect a function to consume a channel, like so:: you can connect a function to consume a channel, like so::
@Channel.consumer("channel-name") from channels.decorators import consumer
@consumer("channel-name")
def my_consumer(something, **kwargs): def my_consumer(something, **kwargs):
pass pass
@ -101,7 +103,7 @@ and a channel per client for responses (e.g. ``django.wsgi.respsonse.o4F2h2Fd``)
with the response channel a property (``send_channel``) of the request message. with the response channel a property (``send_channel``) of the request message.
Suddenly, a view is merely another example of a consumer:: Suddenly, a view is merely another example of a consumer::
@Channel.consumer("django.wsgi.request") @consumer("django.wsgi.request")
def my_consumer(send_channel, **request_data): def my_consumer(send_channel, **request_data):
# Decode the request from JSON-compat to a full object # Decode the request from JSON-compat to a full object
django_request = Request.decode(request_data) django_request = Request.decode(request_data)
@ -181,7 +183,7 @@ set of channels (here, using Redis) to send updates to::
content=instance.content, content=instance.content,
) )
@Channel.consumer("django.websocket.connect") @consumer("django.websocket.connect")
def ws_connect(path, send_channel, **kwargs): def ws_connect(path, send_channel, **kwargs):
# Add to reader set # Add to reader set
redis_conn.sadd("readers", send_channel) redis_conn.sadd("readers", send_channel)
@ -217,8 +219,8 @@ we don't need to; Channels has it built in, as a feature called Groups::
content=instance.content, content=instance.content,
) )
@Channel.consumer("django.websocket.connect") @consumer("django.websocket.connect")
@Channel.consumer("django.websocket.keepalive") @consumer("django.websocket.keepalive")
def ws_connect(path, send_channel, **kwargs): def ws_connect(path, send_channel, **kwargs):
# Add to reader group # Add to reader group
Group("liveblog").add(send_channel) Group("liveblog").add(send_channel)