shkong/OpenShamrock
1
0
Fork 0
mirror of https://github.com/whitechi73/OpenShamrock.git synced 2024-08-14 13:12:17 +08:00
Code Issues Packages Projects Releases Wiki Activity

Shamrock: not fix GlobalEventTransmitter x2

Browse Source
This commit is contained in:
白池 2024-02-11 14:06:10 +08:00
parent 9a9fad975f
commit 65f54360f8
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
xposed/src/main/java/moe/fuqiuluo/shamrock/remote/service/api/GlobalEventTransmitter.kt
View File

@ -33,13 +33,13 @@ import java.util.ArrayList
internal object GlobalEventTransmitter: BaseSvc() { internal object GlobalEventTransmitter: BaseSvc() {
private val messageEventFlow by lazy { private val messageEventFlow by lazy {
MutableSharedFlow<Pair<MsgRecord, MessageEvent>>(3) MutableSharedFlow<Pair<MsgRecord, MessageEvent>>()
} }
private val noticeEventFlow by lazy { private val noticeEventFlow by lazy {
MutableSharedFlow<NoticeEvent>(3) MutableSharedFlow<NoticeEvent>()
} }
private val requestEventFlow by lazy { private val requestEventFlow by lazy {
MutableSharedFlow<RequestEvent>(3) MutableSharedFlow<RequestEvent>()
} }
private suspend fun pushNotice(noticeEvent: NoticeEvent) = noticeEventFlow.emit(noticeEvent) private suspend fun pushNotice(noticeEvent: NoticeEvent) = noticeEventFlow.emit(noticeEvent)
@ -49,7 +49,7 @@ internal object GlobalEventTransmitter: BaseSvc() {
private suspend fun transMessageEvent(record: MsgRecord, message: MessageEvent) = messageEventFlow.emit(record to message) private suspend fun transMessageEvent(record: MsgRecord, message: MessageEvent) = messageEventFlow.emit(record to message)
/** /**
* 消息 手淫器 * 消息
*/ */
object MessageTransmitter { object MessageTransmitter {
/** /**