i ddlZddlmZddlmZ ddlZdZn#e$r ddlmZYnwxYwGddejZ eGddeZ n Gd dZ e ej ej ee ej d ZdS) N)queue)Event)SimpleWebSocketWSGIc.eZdZdZgiffd ZdZxZS)Threadz This wrapper class provides gevent Greenlet interface that is compatible with the standard library's Thread class. cBtj|g|Ri|dSN)super__init__)selftargetargskwargs __class__s H/usr/local/lib/python3.11/dist-packages/engineio/async_drivers/gevent.pyr zThread.__init__s01$111&11111c*|Sr )runr s r_runz Thread._runsxxzzr)__name__ __module__ __qualname____doc__r r __classcell__rs@rrr s]%'r222222rrc"eZdZdZfdZxZS) WebSocketWSGIz This wrapper class provides a gevent WebSocket interface that is compatible with eventlet's implementation, using the simple-websocket package. cddl}ddl}t||t|jj|jjdS)Nr) thread_class event_classselector_class) gevent.eventgevent.selectorsr r reventr selectorsDefaultSelector)r handlerservergeventrs rr zWebSocketWSGI.__init__ se    # # # # GG  Wf*0)/);,2,<,L  N N N N Nr)rrrrr rrs@rrrsK  N N N N N N N N Nrrc0eZdZdZdZdZdZdZdZdS)rz This wrapper class provides a gevent WebSocket interface that is compatible with eventlet's implementation, using the gevent-websocket package. c||_dSr )app)r r(r)s rr zWebSocketWSGI.__init__1s DHHHrcd|vrtd|d|_||_|jj|_|jj|_|jj|_|jj|_||S)Nzwsgi.websocketzThe gevent-websocket server is not configured appropriately. See the Deployment section of the documentation for more information.) RuntimeError_sockenvironversionpathoriginprotocolr-)r r1start_responses r__call__zWebSocketWSGI.__call__4s}w.."$IJJJ!!12DJ"DL:-DL DI*+DK J/DM88D>> !rc4|jSr )r0closers rr9zWebSocketWSGI.closeBs:##%% %rc6|j|Sr )r0send)r messages rr;zWebSocketWSGI.sendEs:??7++ +rc4|jSr )r0receivers rwaitzWebSocketWSGI.waitHs:%%'' 'rN) rrrrr r7r9r;r?rrrr+si      " " " & & & , , , ( ( ( ( (r)threadr queue_emptyr% websocketsleep)r*rr#rgeventwebsocketr ImportError&engineio.async_drivers._websocket_wsgiGreenletrr JoinableQueueEmptyrD_asyncr@rrrLsE KKKKJJJJJJJJK     V_   "NNNNN+NNNN"((((((((D  ;  \   s  ''