File: //usr/lib/python3/dist-packages/twisted/internet/__pycache__/wxreactor.cpython-310.pyc
o
�b� � @ s� d Z ddlmZmZ z ddlmZmZm Z
W n e y) ddl mZmZm
Z
Y nw ddl
mZ ddlmZmZ 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)� CallAfter� PySimpleApp�Timer)�
wxPySimpleApp� wxCallAfter�wxTimer)�_threadedselect)�log�runtimec @ 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 2 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 �
registerWxAppF s
zWxReactor.registerWxAppc C s> zddl }|� |j|j� W n
ty Y dS w | �� dS )zO
wx sometimes removes our own signal handlers, so re-add them.
r N)�signal�SIGINT�default_int_handler� ImportError�_handleSignals)r r r r r �_installSignalHandlersAgainL s � z%WxReactor._installSignalHandlersAgainc C s | j rdS d| _ tj�| � dS )z#
Stop the reactor.
NT)� _stoppingr
�ThreadedSelectReactor�stopr r r r r& Y s zWxReactor.stopc C s& t | d�r t|� dS | 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 �_runInMainThreadb s
zWxReactor._runInMainThreadc C s t | d�r | j�� dS dS )z
Stop the wx event loop if it hasn't already been stopped.
Called during Twisted event loop shutdown.
r N)r' r � ExitMainLoopr r r r �_stopWxn s
�zWxReactor._stopWxTc s t � � _t� d�st�d� � �t� � � j� j|d� |r%� � d� j
� � � dd� j � � � dd� fdd�� t
j�� rGt� j�}|�d � � j�� � j}� `� js�� �� |�� z � jjd d �}W n tyo Y q\w |d
u rvd
S z|� W n
ty� t�� Y nw q]d
S )z$
Start the reactor.
r zMregisterWxApp() was not called on reactor, registering my own wxApp instance.)�installSignalHandlersr �after�shutdownc s � j �d �S r )r( r) r r r r �<lambda>� s z WxReactor.run.<locals>.<lambda>� � g{�G�z�?)�timeoutN)r r( r' r �msgr r �
interleaver+ � callLaterr# �addSystemEventTriggerr- r �platform�isMacOSXr
r �Start�MainLoopr$ r& r �getr �
BaseException�err)r r. �tr r* r r r �runw sN
� ��
�
���z
WxReactor.runN)T) r r r r r$ r r# r& r+ r- rA 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 �twisted.internet.mainrB )�reactorrB r r r �install� s rE N)r �queuer r �wxr r r r r r r! � wxPython.wx�twisted.internetr
�twisted.pythonr r r
r% r rE �__all__r r r r �<module> s � t