OneMoreRun/cn.chahuyun.omr.util/OMRMessageWhereBuild

OMRMessageWhereBuild

object OMRMessageWhereBuild : OMRMessageUtil

OMR消息处理工具对象，提供流程控制相关的便捷方法

Properties

Link copied to clipboard
open override val channel: EventChannel<MessageEvent>

消息事件通道，用于接收和过滤消息事件。 该通道基于全局事件通道创建，并限定在 OneMoreRun 作用域内， 只接收 MessageEvent 类型的事件。

Functions

Link copied to clipboard
fun abort(message: String = ""): Nothing

触发中止流程信号

Link copied to clipboard
fun buildForwardMessage(event: MessageEvent, titleGenerator: String, briefGenerator: String, previewGenerator: List<String>, summarySize: Int, summaryGenerator: String, sourceGenerator: String, block: ForwardMessageBuilder.() -> Unit): ForwardMessage
Link copied to clipboard
suspend fun nextGroupMessage(groupId: Long, timer: Int): MessageChain?
suspend fun nextGroupMessage(group: Group, timer: Int): MessageChain?
Link copied to clipboard
open override fun nextGroupMessageAsync(groupId: Long, timeout: Int, callback: (MessageChain?) -> Unit)
Link copied to clipboard
suspend fun nextGroupMessageEvent(groupId: Long, timer: Int): GroupMessageEvent?
suspend fun nextGroupMessageEvent(group: Group, timer: Int): GroupMessageEvent?
Link copied to clipboard
open override fun nextGroupMessageEventAsync(groupId: Long, timeout: Int, callback: (GroupMessageEvent?) -> Unit)
Link copied to clipboard
open override fun nextGroupMessageEventSync(groupId: Long, timeout: Int): GroupMessageEvent?
Link copied to clipboard
open override fun nextGroupMessageSync(groupId: Long, timeout: Int): MessageChain?
Link copied to clipboard
suspend fun nextMessage(senderId: Long, timer: Int): MessageEvent?
Link copied to clipboard
open override fun nextMessageEventAsync(senderId: Long, timeout: Int, callback: (MessageEvent?) -> Unit)
Link copied to clipboard
open override fun nextMessageEventSync(senderId: Long, timeout: Int): MessageEvent?
Link copied to clipboard
suspend fun nextUserForGroupMessageEvent(groupId: Long, userId: Long, timer: Int): GroupMessageEvent?
Link copied to clipboard
open override fun nextUserForGroupMessageEventAsync(groupId: Long, userId: Long, timeout: Int, callback: (GroupMessageEvent?) -> Unit)
Link copied to clipboard
open override fun nextUserForGroupMessageEventSync(groupId: Long, userId: Long, timeout: Int): GroupMessageEvent?
Link copied to clipboard
fun retry(message: String = ""): Nothing

触发重试流程信号