σ ¨œž[c@`sΫdZddlmZmZmZddlZddlmZddlm Z ddl m Z ddl Z de fd„ƒYZ d e fd „ƒYZd e fd „ƒYZd „Zd„Zde jfd„ƒYZdS(s Bridges between the `asyncio` module and Tornado IOLoop. .. versionadded:: 3.2 This module integrates Tornado with the ``asyncio`` module introduced in Python 3.4. This makes it possible to combine the two libraries on the same event loop. .. deprecated:: 5.0 While the code in this module is still used, it is now enabled automatically when `asyncio` is available, so applications should no longer need to refer to this module directly. .. note:: Tornado requires the `~asyncio.AbstractEventLoop.add_reader` family of methods, so it is not compatible with the `~asyncio.ProactorEventLoop` on Windows. Use the `~asyncio.SelectorEventLoop` instead. i(tabsolute_importtdivisiontprint_functionN(tconvert_yielded(tIOLoop(t stack_contexttBaseAsyncIOLoopcB`s†eZd„Zed„Zd„Zd„Zd„Zd„Zd„Z d„Z d„Z d „Z d „Z e Zd „Zd „ZRS( cK`s||_i|_tƒ|_tƒ|_t|_x0ttj ƒD]}|j ƒrCtj |=qCqCW|tj |RR R0(RR@RAR((s7lib/python2.7/site-packages/tornado/platform/asyncio.pyt add_callback–s  # cG`s|jj|||ŒS(N(Rtrun_in_executor(RtexecutortfuncRA((s7lib/python2.7/site-packages/tornado/platform/asyncio.pyRH₯scC`s|jj|ƒS(N(Rtset_default_executor(RRI((s7lib/python2.7/site-packages/tornado/platform/asyncio.pyRK¨s(t__name__t __module__RR RR)R-RR#R7R8RBRERGtadd_callback_from_signalRHRK(((s7lib/python2.7/site-packages/tornado/platform/asyncio.pyR s          tAsyncIOMainLoopcB`s eZdZd„Zd„ZRS(s›``AsyncIOMainLoop`` creates an `.IOLoop` that corresponds to the current ``asyncio`` event loop (i.e. the one returned by ``asyncio.get_event_loop()``). .. deprecated:: 5.0 Now used automatically when appropriate; it is no longer necessary to refer to this class directly. .. versionchanged:: 5.0 Closing an `AsyncIOMainLoop` now closes the underlying asyncio loop. cK`s#tt|ƒjtjƒ|dS(N(RRORR.R/(RR((s7lib/python2.7/site-packages/tornado/platform/asyncio.pyRΊscC`sdS(N((R((s7lib/python2.7/site-packages/tornado/platform/asyncio.pyt make_current½s(RLRMt__doc__RRP(((s7lib/python2.7/site-packages/tornado/platform/asyncio.pyRO¬s  t AsyncIOLoopcB`s5eZdZd„Zed„Zd„Zd„ZRS(s–``AsyncIOLoop`` is an `.IOLoop` that runs on an ``asyncio`` event loop. This class follows the usual Tornado semantics for creating new ``IOLoops``; these loops are not necessarily related to the ``asyncio`` default event loop. Each ``AsyncIOLoop`` creates a new ``asyncio.EventLoop``; this object can be accessed with the ``asyncio_loop`` attribute. .. versionchanged:: 5.0 When an ``AsyncIOLoop`` becomes the current `.IOLoop`, it also sets the current `asyncio` event loop. .. deprecated:: 5.0 Now used automatically when appropriate; it is no longer necessary to refer to this class directly. cK`sWt|_tjƒ}ytt|ƒj||Wntk rR|jƒ‚nXdS(N( R t is_currentR.tnew_event_loopRRRRt ExceptionR(RRR((s7lib/python2.7/site-packages/tornado/platform/asyncio.pyRΦs    cC`s3|jr|jƒntt|ƒjd|ƒdS(NR(RSt clear_currentRRRR(RR((s7lib/python2.7/site-packages/tornado/platform/asyncio.pyRαs  cC`s_|jsKytjƒ|_Wn ttfk r>d|_nXt|_ntj|j ƒdS(N( RSR.R/t old_asyncioR0R1R2RR4R(R((s7lib/python2.7/site-packages/tornado/platform/asyncio.pyRPζs   cC`s)|jr%tj|jƒt|_ndS(N(RSR.R4RWR (R((s7lib/python2.7/site-packages/tornado/platform/asyncio.pyt_clear_current_hookοs (RLRMRQRR RRPRX(((s7lib/python2.7/site-packages/tornado/platform/asyncio.pyRRΓs   cC`s|S(sίConvert an `asyncio.Future` to a `tornado.concurrent.Future`. .. versionadded:: 4.1 .. deprecated:: 5.0 Tornado ``Futures`` have been merged with `asyncio.Future`, so this method is now a no-op. ((tasyncio_future((s7lib/python2.7/site-packages/tornado/platform/asyncio.pytto_tornado_futureυs cC`s t|ƒS(ssConvert a Tornado yieldable object to an `asyncio.Future`. .. versionadded:: 4.1 .. versionchanged:: 4.3 Now accepts any yieldable object, not just `tornado.concurrent.Future`. .. deprecated:: 5.0 Tornado ``Futures`` have been merged with `asyncio.Future`, so this method is now equivalent to `tornado.gen.convert_yielded`. (R(ttornado_future((s7lib/python2.7/site-packages/tornado/platform/asyncio.pytto_asyncio_futures tAnyThreadEventLoopPolicycB`seZdZd„ZRS(sDEvent loop policy that allows loop creation on any thread. The default `asyncio` event loop policy only automatically creates event loops in the main threads. Other threads must create event loops explicitly or `asyncio.get_event_loop` (and therefore `.IOLoop.current`) will fail. Installing this policy allows event loops to be created automatically on any thread, matching the behavior of Tornado versions prior to 5.0 (or 5.0 on Python 2). Usage:: asyncio.set_event_loop_policy(AnyThreadEventLoopPolicy()) .. versionadded:: 5.0 cC`sIytƒjƒSWn1ttfk rD|jƒ}|j|ƒ|SXdS(N(RR/R0R1RTR4(RR((s7lib/python2.7/site-packages/tornado/platform/asyncio.pyR/"s   (RLRMRQR/(((s7lib/python2.7/site-packages/tornado/platform/asyncio.pyR]s(RQt __future__RRRR=t tornado.genRttornado.ioloopRttornadoRR.RRORRRZR\tDefaultEventLoopPolicyR](((s7lib/python2.7/site-packages/tornado/platform/asyncio.pyts  Œ2