iNSSKrSSKrSSKJr SSKJr SSKJr "SS\5rg)N)packet) BaseManagercb^\rSrSrSrSrS SjrU4SjrSrS Sjr Sr S r S r S r U=r$) AsyncManager z+Manage a client list for an asyncio server.c,# URX5$7fN) is_connected)selfsid namespaces S/home/admin/cozy_coffee/venv/lib/python3.13/site-packages/socketio/async_manager.pycan_disconnectAsyncManager.can_disconnect s  00c N# U=(d UnX0R;ag[U[5(a [U5nO UbU/nO/n[U[5(dU/n/n U(dURR [ RX1/U-S9n U R5n [U [5(dU /n U V s/sH(n [R"[RU 5PM* n n URX45HSupX;dM U HAn U R[R"URR!X555 MC MU OURX45HupX;dM UR#X5nURR [ RX1/U-US9n U R[R"URR%X555 M U /:Xag[R&"U 5IShvN gs sn fN 7f)z}Emit a message to a single client, a room, or all the clients connected to the namespace. Note: this method is a coroutine. N)rdata)rrid)rooms isinstancetuplelistserver packet_classrEVENTencode eio_packetPacketMESSAGEget_participantsappendasyncio create_task_send_eio_packet_generate_ack_id _send_packetwait)r eventrrroomskip_sidcallbacktokwargstaskspktencoded_packetpeio_pktr eio_sidrs remitAsyncManager.emitszT JJ &  dE " ":D  6DD(D)) zH++** $+HC ZZ\Nnd33"0!1 .0 .1"((););Q? . 0 $ 5 5i F &$ W%8%8 KK88D&FG%!G!% 5 5i F &..s=B++22 $3CLL!4!4 00>"@A !G B; ll5!!!-0, "s,B?H%/H0H%A%H%8B H%H# H%c*># [TU]X5$7f)zPRegister a client connection to a namespace. Note: this method is a coroutine. )superconnect)r r4r __class__s rr9AsyncManager.connectCs ww22sc0# UR"X40UD6$7f)z8Disconnect a client. Note: this method is a coroutine. )basic_disconnect)r r rr.s r disconnectAsyncManager.disconnectJs $$S>v>>sc*# URXX4S9$7f)z;Add a client to a room. Note: this method is a coroutine. )r4)basic_enter_room)r r rr*r4s r enter_roomAsyncManager.enter_roomQs $$ST$KKsc.# URXU5$7f)z@Remove a client from a room. Note: this method is a coroutine. )basic_leave_room)r r rr*s r leave_roomAsyncManager.leave_roomXs $$ST::sc,# URX5$7f)zHRemove all participants from a room. Note: this method is a coroutine. )basic_close_room)r r*rs r close_roomAsyncManager.close_room_s $$T55rcL# SnURUUnURUU Ub-U"U6n[R "U5(a UIShvN ggg![a" UR5RS5 N\f=fN6![ Ra gf=f7f)zCInvoke an application callback. Note: this method is a coroutine. Nz$Unknown callback received, ignoring.) callbacksKeyError _get_loggerwarninginspect iscoroutiner#CancelledError)r r rrr,rets rtrigger_callbackAsyncManager.trigger_callbackfs  (~~c*2.H s#B'  D/C""3''II(  O     & &'M N O--s]B$A3B$ B BB B$)BB$BB$B B!B$ B!!B$)NNNNr )__name__ __module__ __qualname____firstlineno____doc__rr5r9r>rBrFrJrU__static_attributes__ __classcell__)r:s@rrr s?51FJ%)3"j3?L;6r) r#rQengineiorrsocketio base_managerrrrWr_rrcs")%p;pr_