ContinuousSessionContext

// 假设这个 session context 的'事件'类型为 Int, '结果'类型为 String
val context = ContinuousSessionContext<Int, String> = ...
val session = context.session(Key()) { // this: ContinuousSessionReceiver
    // receiver 逻辑在异步中，等待外界的事件推送
    val next = await { it -> it.toString() }
}        ↑                       |
         |-------------|         |
                       |         |
      |--------------- | --------|
      |                |
      ↓                |
val result = session.push(1) // 推送 '事件', 得到 '结果'

session.join() // session 内逻辑结束后便会正常终止
assertTrue(session.isCompleted)

suspend fun handle(handleEvent: Event, sessionContext: EventContinuousSessionContext): EventResult {
   // event: 接收到的事件
   // sessionContext: 假设它是在 application 的 plugins 中获取到的. 可参见 `EventContinuousSessionContext` 的文档说明。

   val key = computeKey(handleEvent) // 根据 handleEvent, 分配一个与它的唯一会话对应的 key.
   val session = context.session(key, EXISTING) {
       // this: ContinuousSessionReceiver<Event, EventResult>
       // receiver 逻辑在异步中，等待外界的事件推送
       // 此处的逻辑：
       //   如果收到的事件 event 经过 check 的判断后符合要求，
       //   则返回 EventResult.empty(isTruncated = true), 代表此会话已经截取此事件，
       //   不要让事件再向后续的其他处理器传递；
       //   否则（即不符合你的业务逻辑判断的条件）则返回一个 EventResult.invalid(), 代表无效的结果。
       val next = await { event ->
            ↑           if (check(event)) EventResult.empty(isTruncated = true)
            |           else EventResult.invalid()
            |     }
   }        |     \-----------------------------------------------------------/
            |                       |
            |-------------|         |
                          |         |
         |--------------- | --------|
         ↓                |
   return session.push(handleEvent) // 推送 '事件', 得到 '结果'
   // 直接返回这个结果
}