waitBlocking
fun <T> waitBlocking(id: String, timeout: JavaDuration = JavaDuration.ZERO, blockingListener: BlockingContinuousSessionSelector<T>): T(source)
注册一个持续会话监听函数并阻塞的等待.
如果注册时发现存在 id 冲突的持续会话监听函数,则上一个函数将会被立即关闭处理。
Parameters
id
注册的持续会话监听函数的唯一ID
timeout
超时时间。大于0的时候生效, 最小有效单位为毫秒。
blockingListener
用于java的阻塞监听函数。是 (EventProcessingContext, ContinuousSessionProvider) -> {}
类型的函数接口
See also
Throws
fun <T> waitBlocking(timeout: JavaDuration = JavaDuration.ZERO, blockingListener: BlockingContinuousSessionSelector<T>): T(source)
注册一个持续会话监听函数并阻塞的等待.
Parameters
timeout
超时时间。大于0的时候生效, 最小有效单位为毫秒。
blockingListener
用于java的阻塞监听函数。是 (EventProcessingContext, ContinuousSessionProvider) -> {}
类型的函数接口
See also
Throws
fun <T> waitBlocking(id: String, timeout: Long, timeUnit: TimeUnit, blockingListener: BlockingContinuousSessionSelector<T>): T(source)
注册一个持续会话监听函数并阻塞的等待.
如果注册时发现存在 id 冲突的持续会话监听函数,则上一个函数将会被立即关闭处理。
Parameters
id
注册的持续会话监听函数的唯一ID
timeout
超时时间。大于0的时候生效
timeUnit
timeout 的时间单位。
blockingListener
用于java的阻塞监听函数。是 (EventProcessingContext, ContinuousSessionProvider) -> {}
类型的函数接口
See also
Throws
fun <T> waitBlocking(timeout: Long, timeUnit: TimeUnit, blockingListener: BlockingContinuousSessionSelector<T>): T(source)
注册一个持续会话监听函数并阻塞的等待, id随机。
Parameters
timeout
超时时间,毫秒为单位。大于0的时候生效
blockingListener
用于java的阻塞监听函数。是 (EventProcessingContext, ContinuousSessionProvider) -> {}
类型的函数接口