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: fix GlobalEventTransmitter

Browse Source
This commit is contained in:
白池 2024-02-11 13:42:28 +08:00
parent fdb2486090
commit 7153b21cd4
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
xposed/src/main/java/moe/fuqiuluo/shamrock/remote/service/HttpService.kt
View File

@ -52,7 +52,6 @@ internal object HttpService: HttpTransmitServlet() {
GlobalEventTransmitter.onNoticeEvent { event ->
pushTo(event)
}
})
submitFlowJob(GlobalScope.launch {
GlobalEventTransmitter.onRequestEvent {

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

@ -32,13 +32,13 @@ import java.util.ArrayList
internal object GlobalEventTransmitter: BaseSvc() {
private val messageEventFlow by lazy {
MutableSharedFlow<Pair<MsgRecord, MessageEvent>>()
MutableSharedFlow<Pair<MsgRecord, MessageEvent>>(3)
}
private val noticeEventFlow by lazy {
MutableSharedFlow<NoticeEvent>()
MutableSharedFlow<NoticeEvent>(3)
}
private val requestEventFlow by lazy {
MutableSharedFlow<RequestEvent>()
MutableSharedFlow<RequestEvent>(3)
}
private suspend fun pushNotice(noticeEvent: NoticeEvent) = noticeEventFlow.emit(noticeEvent)
@ -556,7 +556,8 @@ internal object GlobalEventTransmitter: BaseSvc() {
@ShamrockDsl
suspend inline fun onMessageEvent(collector: FlowCollector<Pair<MsgRecord, MessageEvent>>) {
messageEventFlow.collect(collector)
messageEventFlow
.collect(collector)
}
@ShamrockDsl