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