diff --git a/.gitignore b/.gitignore index ce2db2b4..2fc9d462 100644 --- a/.gitignore +++ b/.gitignore @@ -53,4 +53,5 @@ dist doc -mkdoc2.py \ No newline at end of file +mkdoc2.py +result.json \ No newline at end of file diff --git a/liteyuki/comm/channel.py b/liteyuki/comm/channel.py index 3355be08..8adb487d 100644 --- a/liteyuki/comm/channel.py +++ b/liteyuki/comm/channel.py @@ -217,16 +217,6 @@ class Channel(Generic[T]): data = self.conn_recv.recv() self._run_on_sub_receive_funcs(data) - def __iter__(self): - return self - - def __next__(self) -> Any: - return self.receive() - - def __del__(self): - self.close() - logger.debug(f"Channel {self.name} deleted.") - """子进程可用的主动和被动通道""" active_channel: Optional["Channel"] = None diff --git a/src/nonebot_plugins/to_liteyuki.py b/src/nonebot_plugins/to_liteyuki.py index 8358db5c..ddf0c15d 100644 --- a/src/nonebot_plugins/to_liteyuki.py +++ b/src/nonebot_plugins/to_liteyuki.py @@ -8,6 +8,8 @@ Copyright (C) 2020-2024 LiteyukiStudio. All Rights Reserved @File : to_liteyuki.py @Software: PyCharm """ +import asyncio + from nonebot import Bot, get_bot, on_message from nonebot.plugin import PluginMetadata from nonebot.adapters.onebot.v11 import MessageEvent, Bot @@ -37,6 +39,8 @@ async def _(bot: Bot, event: MessageEvent): @shared_memory.on_subscriber_receive("event_to_nonebot") -async def _(event: MessageEvent): +async def _(event: LiteyukiMessageEvent): bot: Bot = get_bot(event.bot_id) + print("A") await bot.send_msg(message_type=event.message_type, user_id=int(event.session_id), group_id=int(event.session_id), message=event.data["message"]) + print("B") \ No newline at end of file