django/daphne
1
1
Fork 0
mirror of https://github.com/django/daphne.git synced 2024-11-21 23:46:33 +03:00
Code Issues Packages Projects Releases Wiki Activity

Used partial() to wrap Server.handle_reply() (#364)

Browse Source 
Fixes #332.
This commit is contained in:
Adam Johnson 2021-04-07 19:14:02 +01:00 committed by GitHub
parent ca61162129
commit 2b6f153616
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
CHANGELOG.txt
View File

@ -1,3 +1,7 @@
* Fixed a bug where ``send`` passed to applications wasn't a true async
function but a lambda wrapper, preventing it from being used with
``asgiref.sync.async_to_sync()``.
3.0.1 (2020-11-12) 3.0.1 (2020-11-12)
------------------ ------------------

3
daphne/server.py
View File

@ -22,6 +22,7 @@ else:
import logging import logging
import time import time
from concurrent.futures import CancelledError from concurrent.futures import CancelledError
from functools import partial
from twisted.internet import defer, reactor from twisted.internet import defer, reactor
from twisted.internet.endpoints import serverFromString from twisted.internet.endpoints import serverFromString
@ -203,7 +204,7 @@ class Server:
application_instance = self.application( application_instance = self.application(
scope=scope, scope=scope,
receive=input_queue.get, receive=input_queue.get,
send=lambda message: self.handle_reply(protocol, message), send=partial(self.handle_reply, protocol),
) )
# Run it, and stash the future for later checking # Run it, and stash the future for later checking
if protocol not in self.connections: if protocol not in self.connections: