3 \]@s(ddlZddlmZGdddeZdS)N) BaseManagercs2eZdZdZd ddZfddZddZZS) AsyncManagerz+Manage a client list for an asyncio server.Nc s||jks||j|krdSg}t|ts0|g}xR|j||D]B} | |kr>|dk rb|j| ||} nd} |j|jj| |||| q>W|gkrdStj |IdHdS)zEmit a message to a single client, a room, or all the clients connected to the namespace. Note: this method is a coroutine. N) Zrooms isinstancelistZget_participantsZ_generate_ack_idappendserverZ_emit_internalasynciowait) selfeventdata namespaceroomZskip_sidcallbackkwargsZtaskssididrC/tmp/pip-build-mqc4i71p/python-socketio/socketio/asyncio_manager.pyemits zAsyncManager.emitcstj||S)zXRemove all participants from a room. Note: this method is a coroutine. )super close_room)r rr) __class__rrr szAsyncManager.close_roomcsd}y|j|||}Wn"tk r<|jjdYnX|j|||=|dk r||}tj|ry|IdHWntjk rYnXdS)zSInvoke an application callback. Note: this method is a coroutine. Nz$Unknown callback received, ignoring.) callbacksKeyErrorZ _get_loggerwarningr iscoroutineZCancelledError)r rrrr rretrrrtrigger_callback's zAsyncManager.trigger_callback)NNN)__name__ __module__ __qualname____doc__rrr __classcell__rr)rrrs   r)r Z base_managerrrrrrrs