wg ddlZddlmZddlmZ ddlZdZGddejZ e GddeZ n Gd dZ e ejejee ejd Zy#e$r ddlmZYbwxYw) N)queue)Event)SimpleWebSocketWSGIc.eZdZdZgiffd ZdZxZS)Threadz This wrapper class provides gevent Greenlet interface that is compatible with the standard library's Thread class. c,t||g|i|yN)super__init__)selftargetargskwargs __class__s b/home/mcse/projects/flask/flask-venv/lib/python3.12/site-packages/engineio/async_drivers/gevent.pyr zThread.__init__s 1$1&1c"|jSr )runr s r_runz Thread._runsxxzr)__name__ __module__ __qualname____doc__r r __classcell__rs@rrr s%'r2rrc"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|j j |jjy)Nr) thread_class event_classselector_class) gevent.eventgevent.selectorsr r reventr selectorsDefaultSelector)r handlerservergeventrs rr zWebSocketWSGI.__init__ sA # G Wf*0)/););,2,<,<,L,L  Nr)rrrrr rrs@rrrs N Nrrc.eZdZdZdZdZdZdZdZy)rz This wrapper class provides a gevent WebSocket interface that is compatible with eventlet's implementation, using the gevent-websocket package. c||_yr )app)r r(r)s rr zWebSocketWSGI.__init__1s DHrc<d|vr td|d|_||_|jj|_|jj|_|jj |_|jj |_|j|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__4sw."$IJJ!!12DJ"DL::--DL DI**++DK JJ//DM88D> !rc6|jjSr )r0closers rr9zWebSocketWSGI.closeBs::##% %rc8|jj|Sr )r0send)r messages rr;zWebSocketWSGI.sendEs::??7+ +rc6|jjSr )r0receivers rwaitzWebSocketWSGI.waitHs::%%' 'rN) rrrrr r7r9r;r?rrrr+s    " & , (r)threadr queue_emptyr% websocketsleep)r*rr#rgeventwebsocketr ImportError&engineio.async_drivers._websocket_wsgiGreenletrr JoinableQueueEmptyrD_asyncr@rrrLs K V__ "N+N"((D  ;;  \\  IKJKsA-- A;:A;