Skip to content

M
Mirai
Commit ed11f38b authored by Him188's avatar Him188
Browse files
Options

Use MONITOR priority for subscribeMessages by default

parent a1322076
Hide whitespace changes
Inline Side-by-side
Showing with 10 additions and 10 deletions
mirai-core/src/commonMain/kotlin/net.mamoe.mirai/event/subscribeMessages.kt
View file @ ed11f38b
...@@ -39,7 +39,7 @@ typealias MessagePacketSubscribersBuilder = MessageSubscribersBuilder<MessageEve ...@@ -39,7 +39,7 @@ typealias MessagePacketSubscribersBuilder = MessageSubscribersBuilder<MessageEve
fun <R> CoroutineScope.subscribeMessages( fun <R> CoroutineScope.subscribeMessages(
coroutineContext: CoroutineContext = EmptyCoroutineContext, coroutineContext: CoroutineContext = EmptyCoroutineContext,
concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT, concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT,
priority: Listener.EventPriority = Listener.EventPriority.NORMAL, priority: Listener.EventPriority = Listener.EventPriority.MONITOR,
listeners: MessagePacketSubscribersBuilder.() -> R listeners: MessagePacketSubscribersBuilder.() -> R
): R { ): R {
// contract 可帮助 IDE 进行类型推断. 无实际代码作用. // contract 可帮助 IDE 进行类型推断. 无实际代码作用.
...@@ -71,7 +71,7 @@ typealias GroupMessageSubscribersBuilder = MessageSubscribersBuilder<GroupMessag ...@@ -71,7 +71,7 @@ typealias GroupMessageSubscribersBuilder = MessageSubscribersBuilder<GroupMessag
fun <R> CoroutineScope.subscribeGroupMessages( fun <R> CoroutineScope.subscribeGroupMessages(
coroutineContext: CoroutineContext = EmptyCoroutineContext, coroutineContext: CoroutineContext = EmptyCoroutineContext,
concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT, concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT,
priority: Listener.EventPriority = Listener.EventPriority.NORMAL, priority: Listener.EventPriority = Listener.EventPriority.MONITOR,
listeners: GroupMessageSubscribersBuilder.() -> R listeners: GroupMessageSubscribersBuilder.() -> R
): R { ): R {
contract { contract {
...@@ -97,7 +97,7 @@ typealias FriendMessageSubscribersBuilder = MessageSubscribersBuilder<FriendMess ...@@ -97,7 +97,7 @@ typealias FriendMessageSubscribersBuilder = MessageSubscribersBuilder<FriendMess
fun <R> CoroutineScope.subscribeFriendMessages( fun <R> CoroutineScope.subscribeFriendMessages(
coroutineContext: CoroutineContext = EmptyCoroutineContext, coroutineContext: CoroutineContext = EmptyCoroutineContext,
concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT, concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT,
priority: Listener.EventPriority = Listener.EventPriority.NORMAL, priority: Listener.EventPriority = Listener.EventPriority.MONITOR,
listeners: FriendMessageSubscribersBuilder.() -> R listeners: FriendMessageSubscribersBuilder.() -> R
): R { ): R {
contract { contract {
...@@ -123,7 +123,7 @@ typealias TempMessageSubscribersBuilder = MessageSubscribersBuilder<TempMessageE ...@@ -123,7 +123,7 @@ typealias TempMessageSubscribersBuilder = MessageSubscribersBuilder<TempMessageE
fun <R> CoroutineScope.subscribeTempMessages( fun <R> CoroutineScope.subscribeTempMessages(
coroutineContext: CoroutineContext = EmptyCoroutineContext, coroutineContext: CoroutineContext = EmptyCoroutineContext,
concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT, concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT,
priority: Listener.EventPriority = Listener.EventPriority.NORMAL, priority: Listener.EventPriority = Listener.EventPriority.MONITOR,
listeners: TempMessageSubscribersBuilder.() -> R listeners: TempMessageSubscribersBuilder.() -> R
): R { ): R {
contract { contract {
...@@ -147,7 +147,7 @@ fun <R> CoroutineScope.subscribeTempMessages( ...@@ -147,7 +147,7 @@ fun <R> CoroutineScope.subscribeTempMessages(
fun <R> Bot.subscribeMessages( fun <R> Bot.subscribeMessages(
coroutineContext: CoroutineContext = EmptyCoroutineContext, coroutineContext: CoroutineContext = EmptyCoroutineContext,
concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT, concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT,
priority: Listener.EventPriority = Listener.EventPriority.NORMAL, priority: Listener.EventPriority = Listener.EventPriority.MONITOR,
listeners: MessagePacketSubscribersBuilder.() -> R listeners: MessagePacketSubscribersBuilder.() -> R
): R { ): R {
contract { contract {
...@@ -173,7 +173,7 @@ fun <R> Bot.subscribeMessages( ...@@ -173,7 +173,7 @@ fun <R> Bot.subscribeMessages(
fun <R> Bot.subscribeGroupMessages( fun <R> Bot.subscribeGroupMessages(
coroutineContext: CoroutineContext = EmptyCoroutineContext, coroutineContext: CoroutineContext = EmptyCoroutineContext,
concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT, concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT,
priority: Listener.EventPriority = Listener.EventPriority.NORMAL, priority: Listener.EventPriority = Listener.EventPriority.MONITOR,
listeners: GroupMessageSubscribersBuilder.() -> R listeners: GroupMessageSubscribersBuilder.() -> R
): R { ): R {
contract { contract {
...@@ -197,7 +197,7 @@ fun <R> Bot.subscribeGroupMessages( ...@@ -197,7 +197,7 @@ fun <R> Bot.subscribeGroupMessages(
fun <R> Bot.subscribeFriendMessages( fun <R> Bot.subscribeFriendMessages(
coroutineContext: CoroutineContext = EmptyCoroutineContext, coroutineContext: CoroutineContext = EmptyCoroutineContext,
concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT, concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT,
priority: Listener.EventPriority = Listener.EventPriority.NORMAL, priority: Listener.EventPriority = Listener.EventPriority.MONITOR,
listeners: FriendMessageSubscribersBuilder.() -> R listeners: FriendMessageSubscribersBuilder.() -> R
): R { ): R {
contract { contract {
...@@ -222,7 +222,7 @@ fun <R> Bot.subscribeFriendMessages( ...@@ -222,7 +222,7 @@ fun <R> Bot.subscribeFriendMessages(
fun <R> Bot.subscribeTempMessages( fun <R> Bot.subscribeTempMessages(
coroutineContext: CoroutineContext = EmptyCoroutineContext, coroutineContext: CoroutineContext = EmptyCoroutineContext,
concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT, concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT,
priority: Listener.EventPriority = Listener.EventPriority.NORMAL, priority: Listener.EventPriority = Listener.EventPriority.MONITOR,
listeners: TempMessageSubscribersBuilder.() -> R listeners: TempMessageSubscribersBuilder.() -> R
): R { ): R {
contract { contract {
...@@ -252,7 +252,7 @@ fun <R> Bot.subscribeTempMessages( ...@@ -252,7 +252,7 @@ fun <R> Bot.subscribeTempMessages(
inline fun <reified E : Event> CoroutineScope.incoming( inline fun <reified E : Event> CoroutineScope.incoming(
coroutineContext: CoroutineContext = EmptyCoroutineContext, coroutineContext: CoroutineContext = EmptyCoroutineContext,
concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT, concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT,
priority: Listener.EventPriority = Listener.EventPriority.NORMAL, priority: Listener.EventPriority = Listener.EventPriority.MONITOR,
capacity: Int = Channel.UNLIMITED capacity: Int = Channel.UNLIMITED
): ReceiveChannel<E> { ): ReceiveChannel<E> {
return Channel<E>(capacity).apply { return Channel<E>(capacity).apply {
...@@ -281,7 +281,7 @@ inline fun <reified E : Event> CoroutineScope.incoming( ...@@ -281,7 +281,7 @@ inline fun <reified E : Event> CoroutineScope.incoming(
inline fun <reified E : BotEvent> Bot.incoming( inline fun <reified E : BotEvent> Bot.incoming(
coroutineContext: CoroutineContext = EmptyCoroutineContext, coroutineContext: CoroutineContext = EmptyCoroutineContext,
concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT, concurrencyKind: Listener.ConcurrencyKind = Listener.ConcurrencyKind.CONCURRENT,
priority: Listener.EventPriority = Listener.EventPriority.NORMAL, priority: Listener.EventPriority = Listener.EventPriority.MONITOR,
capacity: Int = Channel.UNLIMITED capacity: Int = Channel.UNLIMITED
): ReceiveChannel<E> { ): ReceiveChannel<E> {
return Channel<E>(capacity).apply { return Channel<E>(capacity).apply {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment