ElapsingDreams/LiteyukiBot
1
0
Fork 0
forked from bot/app
Code Pull Requests Activity

🔥 移除通道的部分特性

Browse Source
This commit is contained in:
远野千束 2024-08-22 07:23:44 +08:00
parent 9ed4c1abb1
commit a3a31a2c94
3 changed files with 7 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
.gitignore vendored
View File

@ -54,3 +54,4 @@ dist
doc doc
mkdoc2.py mkdoc2.py
result.json

10
liteyuki/comm/channel.py
View File

@ -217,16 +217,6 @@ class Channel(Generic[T]):
data = self.conn_recv.recv() data = self.conn_recv.recv()
self._run_on_sub_receive_funcs(data) 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 active_channel: Optional["Channel"] = None

6
src/nonebot_plugins/to_liteyuki.py
View File

@ -8,6 +8,8 @@ Copyright (C) 2020-2024 LiteyukiStudio. All Rights Reserved
@File : to_liteyuki.py @File : to_liteyuki.py
@Software: PyCharm @Software: PyCharm
""" """
import asyncio
from nonebot import Bot, get_bot, on_message from nonebot import Bot, get_bot, on_message
from nonebot.plugin import PluginMetadata from nonebot.plugin import PluginMetadata
from nonebot.adapters.onebot.v11 import MessageEvent, Bot 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") @shared_memory.on_subscriber_receive("event_to_nonebot")
async def _(event: MessageEvent): async def _(event: LiteyukiMessageEvent):
bot: Bot = get_bot(event.bot_id) 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"]) 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")