simbot-extension-continuous-session/love.forte.simbot.extension.continuous.session/ContinuousSessionReceiver

ContinuousSessionReceiver

interface ContinuousSessionReceiver<out T, R> : CoroutineScope(source)

一组 Session 的元素之一，用来在异步中接收 ContinuousSessionProvider 推送的事件 T 并根据此事件为其返回结果 R。

val session = context.session(Key()) {
    val next = await { v -> v.toResult() } // 假设 toResult() 将事件转化为结果
}         ↑                      |
      |-- | ---------------------|
      |   |-----------|
      ↓               |
val result = session.push(value) // 此处得到 v.toResult() 的结果

Author

ForteScarlet

Inheritors

ContinuousSession

Properties

coroutineContext

abstract override val coroutineContext: CoroutineContext

ContinuousSessionReceiver 作为 CoroutineScope 的协程上下文。其中不会包含 Job。

Functions

await

abstract suspend fun await(): SessionContinuation<T, R>

等待 ContinuousSessionProvider 的下一次推送结果，并将此结果和推送]ContinuousSessionProvider.push 处的挂起点打包为 SessionContinuation，并在稍后通过 SessionContinuation.resume 或 SessionContinuation.resumeWithException 恢复。

abstract suspend fun await(result: R): T

等待 ContinuousSessionProvider 的下一次推送，并在接收到时恢复一个结果 result。

abstract suspend fun await(result: (T) -> R): T

等待 ContinuousSessionProvider 的下一次推送，并在接收到时恢复一个由 result 计算的结果。