File: //proc/self/root/lib/python3/dist-packages/twisted/internet/__pycache__/wxreactor.cpython-38.pyc
U
s�@g� � @ s� d Z zddlmZmZ W n$ ek
r< ddlmZmZ Y nX zddlmZmZ m
Z W n( ek
r~ ddl mZm Z m Z Y nX ddl
mZmZ ddlmZ G dd� de �ZG d d
� d
ej�Zd d � Zd gZd
S )aa
This module provides wxPython event loop support for Twisted.
In order to use this support, simply do the following::
| from twisted.internet import wxreactor
| wxreactor.install()
Then, when your root wxApp has been created::
| from twisted.internet import reactor
| reactor.registerWxApp(yourApp)
| reactor.run()
Then use twisted.internet APIs as usual. Stop the event loop using
reactor.stop(), not yourApp.ExitMainLoop().
IMPORTANT: tests will fail when run under this reactor. This is
expected and probably does not reflect on the reactor's ability to run
real applications.
� )�Empty�Queue)�App� CallAfter�Timer)�wxApp� wxCallAfter�wxTimer)�log�runtime)�_threadedselectc @ s e Zd ZdZdd� Zdd� ZdS )�ProcessEventsTimerz�
Timer that tells wx to process pending events.
This is necessary on macOS, probably due to a bug in wx, if we want
wxCallAfters to be handled when modal dialogs, menus, etc. are open.
c C s t �| � || _d S �N)r �__init__�wxapp��selfr � r �</usr/lib/python3/dist-packages/twisted/internet/wxreactor.pyr 1 s
zProcessEventsTimer.__init__c C s | j �� dS )z5
Called repeatedly by wx event loop.
N)r �ProcessPendingEvents�r r r r �Notify6 s zProcessEventsTimer.NotifyN)�__name__�
__module__� __qualname__�__doc__r r r r r r r
* s r
c @ sF e Zd ZdZdZdd� Zdd� Zdd� Zd d
� Zd d � Z ddd�Z
dS )� WxReactorz[
wxPython reactor.
wxPython drives the event loop, select() runs in a thread.
Fc C s
|| _ dS )z;
Register wxApp instance with the reactor.
N)r r r r r �
registerWxAppG s zWxReactor.registerWxAppc C s@ z ddl }|� |j|j� W n tk
r2 Y dS X | �� dS )zO
wx sometimes removes our own signal handlers, so re-add them.
r N)�signal�SIGINT�default_int_handler� ImportErrorZ_handleSignals)r r r r r �_installSignalHandlersAgainN s z%WxReactor._installSignalHandlersAgainc C s | j r
dS d| _ tj�| � dS )z#
Stop the reactor.
NT)� _stoppingr �ThreadedSelectReactor�stopr r r r r% [ s zWxReactor.stopc C s$ t | d�rt|� n | j�|� dS )zm
Schedule function to run in main wx/Twisted thread.
Called by the select() thread.
r N)�hasattrr �
_postQueue�put)r �fr r r �_runInMainThreade s
zWxReactor._runInMainThreadc C s t | d�r| j�� dS )z
Stop the wx event loop if it hasn't already been stopped.
Called during Twisted event loop shutdown.
r N)r& r Z ExitMainLoopr r r r �_stopWxr s
zWxReactor._stopWxTc s t � � _t� d�s*t�d� � �td�� � j� j|d� |rL� � d� j
� � � dd� j � � � dd� fdd �� t
j�� r�t� j�}|�d
� � j�� � j}� `� j�s� �� |�� z� jjd d �}W n tk
r� Y q�Y q�X |d
kr�qz
|� W q� t�� Y q�X q�d
S )z$
Start the reactor.
r zMregisterWxApp() was not called on reactor, registering my own wxApp instance.F)�installSignalHandlersr ZafterZshutdownc s � j �d �S r )r' r( r r r r �<lambda>� � z WxReactor.run.<locals>.<lambda>� g{�G�z�?)ZtimeoutN)r r' r& r
�msgr r Z
interleaver* Z callLaterr" ZaddSystemEventTriggerr+ r �platformZisMacOSXr
r ZStartZMainLoopr# r% r �getr �err)r r, �tr r) r r r �run| s@
�
�
z
WxReactor.runN)T) r r r r r# r r" r% r* r+ r5 r r r r r > s
r c C s t � } ddlm} || � | S )zP
Configure the twisted mainloop to be run inside the wxPython mainloop.
r )�installReactor)r Ztwisted.internet.mainr6 )Zreactorr6 r r r �install� s r7 N)r Zqueuer r r! Zwxr r r r r r Z wxPython.wxZtwisted.pythonr
r Ztwisted.internetr r
r$ r r7 �__all__r r r r �<module> s t