2BfZ.ddlZddlmZGddeZy)N) BaseManagerc:eZdZdZdZ ddZfdZdZxZS) AsyncManagerz+Manage a client list for an asyncio server.c.K|j||Sw)N) is_connected)selfsid namespaces X/var/www/highfloat_scraper/venv/lib/python3.12/site-packages/socketio/asyncio_manager.pycan_disconnectzAsyncManager.can_disconnects  i00sc K||jvs||j|vryg}t|ts|g}|j||D]O\} } | |vs ||j | |} nd} |j |j j| |||| Q|gk(rytj|d{y7w)zEmit a message to a single client, a room, or all the clients connected to the namespace. Note: this method is a coroutine. N) rooms isinstancelistget_participants_generate_ack_idappendserver_emit_internalasynciowait) r eventdatar roomskip_sidcallbackkwargstasksr eio_sidids r emitzAsyncManager.emit s DJJ &$djj6K*K (D) zH 11)TB HLC("'..sH=BB T[[778A2GH  H B; ll5!!!sACA%C:C;Cc,Kt|||Sw)zXRemove all participants from a room. Note: this method is a coroutine. )super close_room)r rr __class__s r r%zAsyncManager.close_room#s w!$ 22sc:Kd} |j||}|j||=|'||}t j |r |d{yyy#t$r"|jjdYTwxYw75#tj $rYywxYww)zSInvoke an application callback. Note: this method is a coroutine. Nz$Unknown callback received, ignoring.) callbacksKeyError _get_loggerwarningr iscoroutineCancelledError)r r r!rrrets r trigger_callbackzAsyncManager.trigger_callback*s  (~~c*2.H s#B'  D/C""3'II(  O     & &'M N O--s]BA,BB B BB(A=:B<A==BBBBBB)NNN) __name__ __module__ __qualname____doc__r r"r%r/ __classcell__)r&s@r rrs$51FJ "03r)r base_managerrrr5r r8s%7;7r5