next

挂起并等待在具体的事件 Event 环境下根据条件获取下一个匹配的 事件.

通过 next 进行匹配的事件，会根据对应的事件类型结合当前的 Event 的类型进行匹配。

next 对事件类型进行的对应的匹配规则对照表如下:

如果你希望使用更复杂是匹配逻辑，请通过 waitingForNext 来自行编写逻辑。

超时处理

使用 withTimeout 或其衍生函数来进行超时控制。

val session: ContinuousSessionContext = ...

withTimeout(5.seconds) {
   session {
      next(id, FooEvent) { event -> // this: EventProcessingContext
        // ...
        true
      }
   }
}

你可能注意到了上述示例中出现了如下用法：

session {
   next(id, FooEvent) { /* ... */}
}

这是通过扩展函数 ContinuousSessionContext.invoke 所提供的，旨在简化 next 这类函数的使用。

See also

Parameters

挂起并等待在具体的事件 Event 环境下根据条件获取下一个匹配的 事件.

通过 next 进行匹配的事件，会根据对应的事件类型结合当前的 Event 的类型进行匹配。

更多说明请参考 Event.next.

See also

挂起并等待在当前的事件处理上下文 EventProcessingContext 中根据条件获取下一个匹配的 事件.

通过 next 进行匹配的事件，会根据对应的事件类型结合当前的 EventProcessingContext.event 的类型进行匹配。

更多说明参考 Event.next.

See also

挂起并等待在具体的事件 Event 环境下根据条件获取下一个匹配的 事件.

通过 next 进行匹配的事件，会根据对应的事件类型结合当前的 Event 的类型进行匹配。

next 对事件类型进行的对应的匹配规则对照表如下:

如果你希望使用更复杂是匹配逻辑，请通过 waitingForNext 来自行编写逻辑。

超时处理

使用 withTimeout 或其衍生函数来进行超时控制。

val session: ContinuousSessionContext = ...

withTimeout(5.seconds) {
   session {
      next { event -> // this: EventProcessingContext
        // ...
        true
      }
   }
}

你可能注意到了上述示例中出现了如下用法：

session {
   next(id, FooEvent) { /* ... */}
}

这是通过扩展函数 ContinuousSessionContext.invoke 所提供的，旨在简化 next 这类函数的使用。

See also

Parameters