django/daphne
1
1
Fork 0
mirror of https://github.com/django/daphne.git synced 2025-07-29 16:39:46 +03:00
Code Issues Packages Projects Releases Wiki Activity

Modify code style

Browse Source
This commit is contained in:
kuratowski 2019-02-06 00:22:06 +09:00 committed by Carlton Gibson
parent 13abad2f89
commit c57252a9fc
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
daphne/testing.py
View File

@ -126,9 +126,11 @@ class DaphneProcess(multiprocessing.Process):
# This is necessary because asyncio behaves badly with multiprocessing. # This is necessary because asyncio behaves badly with multiprocessing.
from twisted.internet import asyncioreactor from twisted.internet import asyncioreactor
import sys import sys
current_reactor = sys.modules.get("twisted.internet.reactor") current_reactor = sys.modules.get("twisted.internet.reactor")
if isinstance(current_reactor, asyncioreactor.AsyncioSelectorReactor): if isinstance(current_reactor, asyncioreactor.AsyncioSelectorReactor):
import asyncio import asyncio
current_reactor._asyncioEventloop.close() current_reactor._asyncioEventloop.close()
asyncio.set_event_loop(asyncio.new_event_loop()) asyncio.set_event_loop(asyncio.new_event_loop())
current_reactor._asyncioEventloop = asyncio.get_event_loop() current_reactor._asyncioEventloop = asyncio.get_event_loop()