From ed11f38b3f3a838e982868817e9da0e473a0b7a6 Mon Sep 17 00:00:00 2001 From: Him188 Date: Thu, 7 May 2020 10:47:23 +0800 Subject: [PATCH] Use MONITOR priority for subscribeMessages by default --- .../event/subscribeMessages.kt | 20 +++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/mirai-core/src/commonMain/kotlin/net.mamoe.mirai/event/subscribeMessages.kt b/mirai-core/src/commonMain/kotlin/net.mamoe.mirai/event/subscribeMessages.kt index c61677db1..787171910 100644 --- a/mirai-core/src/commonMain/kotlin/net.mamoe.mirai/event/subscribeMessages.kt +++ b/mirai-core/src/commonMain/kotlin/net.mamoe.mirai/event/subscribeMessages.kt @@ -39,7 +39,7 @@ typealias MessagePacketSubscribersBuilder = MessageSubscribersBuilder CoroutineScope.subscribeMessages( coroutineContext: CoroutineContext = EmptyCoroutineContext, concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT, - priority: Listener.EventPriority = Listener.EventPriority.NORMAL, + priority: Listener.EventPriority = Listener.EventPriority.MONITOR, listeners: MessagePacketSubscribersBuilder.() -> R ): R { // contract 可帮助 IDE 进行类型推断. 无实际代码作用. @@ -71,7 +71,7 @@ typealias GroupMessageSubscribersBuilder = MessageSubscribersBuilder CoroutineScope.subscribeGroupMessages( coroutineContext: CoroutineContext = EmptyCoroutineContext, concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT, - priority: Listener.EventPriority = Listener.EventPriority.NORMAL, + priority: Listener.EventPriority = Listener.EventPriority.MONITOR, listeners: GroupMessageSubscribersBuilder.() -> R ): R { contract { @@ -97,7 +97,7 @@ typealias FriendMessageSubscribersBuilder = MessageSubscribersBuilder CoroutineScope.subscribeFriendMessages( coroutineContext: CoroutineContext = EmptyCoroutineContext, concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT, - priority: Listener.EventPriority = Listener.EventPriority.NORMAL, + priority: Listener.EventPriority = Listener.EventPriority.MONITOR, listeners: FriendMessageSubscribersBuilder.() -> R ): R { contract { @@ -123,7 +123,7 @@ typealias TempMessageSubscribersBuilder = MessageSubscribersBuilder CoroutineScope.subscribeTempMessages( coroutineContext: CoroutineContext = EmptyCoroutineContext, concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT, - priority: Listener.EventPriority = Listener.EventPriority.NORMAL, + priority: Listener.EventPriority = Listener.EventPriority.MONITOR, listeners: TempMessageSubscribersBuilder.() -> R ): R { contract { @@ -147,7 +147,7 @@ fun CoroutineScope.subscribeTempMessages( fun Bot.subscribeMessages( coroutineContext: CoroutineContext = EmptyCoroutineContext, concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT, - priority: Listener.EventPriority = Listener.EventPriority.NORMAL, + priority: Listener.EventPriority = Listener.EventPriority.MONITOR, listeners: MessagePacketSubscribersBuilder.() -> R ): R { contract { @@ -173,7 +173,7 @@ fun Bot.subscribeMessages( fun Bot.subscribeGroupMessages( coroutineContext: CoroutineContext = EmptyCoroutineContext, concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT, - priority: Listener.EventPriority = Listener.EventPriority.NORMAL, + priority: Listener.EventPriority = Listener.EventPriority.MONITOR, listeners: GroupMessageSubscribersBuilder.() -> R ): R { contract { @@ -197,7 +197,7 @@ fun Bot.subscribeGroupMessages( fun Bot.subscribeFriendMessages( coroutineContext: CoroutineContext = EmptyCoroutineContext, concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT, - priority: Listener.EventPriority = Listener.EventPriority.NORMAL, + priority: Listener.EventPriority = Listener.EventPriority.MONITOR, listeners: FriendMessageSubscribersBuilder.() -> R ): R { contract { @@ -222,7 +222,7 @@ fun Bot.subscribeFriendMessages( fun Bot.subscribeTempMessages( coroutineContext: CoroutineContext = EmptyCoroutineContext, concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT, - priority: Listener.EventPriority = Listener.EventPriority.NORMAL, + priority: Listener.EventPriority = Listener.EventPriority.MONITOR, listeners: TempMessageSubscribersBuilder.() -> R ): R { contract { @@ -252,7 +252,7 @@ fun Bot.subscribeTempMessages( inline fun CoroutineScope.incoming( coroutineContext: CoroutineContext = EmptyCoroutineContext, concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT, - priority: Listener.EventPriority = Listener.EventPriority.NORMAL, + priority: Listener.EventPriority = Listener.EventPriority.MONITOR, capacity: Int = Channel.UNLIMITED ): ReceiveChannel { return Channel(capacity).apply { @@ -281,7 +281,7 @@ inline fun CoroutineScope.incoming( inline fun Bot.incoming( coroutineContext: CoroutineContext = EmptyCoroutineContext, concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT, - priority: Listener.EventPriority = Listener.EventPriority.NORMAL, + priority: Listener.EventPriority = Listener.EventPriority.MONITOR, capacity: Int = Channel.UNLIMITED ): ReceiveChannel { return Channel(capacity).apply {