wait For Next Blocking

如果超时

被终止

@JvmName(name = "waitingForNext")

fun <E : Event> waitForNextBlocking(id: String, key: Event.Key<E>, matcher: BlockingContinuousSessionEventMatcher<E>): E(source)

阻塞并等待下一个符合条件的事件对象。

Parameters

持续会话监听函数的唯一ID

key

事件类型 Event.Key

matcher

匹配函数。相当于 (EventProcessingContext, Event) -> Boolean

Throws

如果超时

被终止

@JvmName(name = "waitingForNext")

fun <E : Event> waitForNextBlocking(key: Event.Key<E>, timeoutDuration: JavaDuration = JavaDuration.ZERO, matcher: BlockingContinuousSessionEventMatcher<E> = BlockingContinuousSessionEventMatcher): E(source)

阻塞并等待下一个符合条件的事件对象。

Parameters

key

事件类型 Event.Key

timeoutDuration

超时时间，大于0时生效。最小有效单位为毫秒。

matcher

匹配函数。相当于 (EventProcessingContext, Event) -> Boolean

Throws

如果超时

被终止

@JvmName(name = "waitingForNext")

fun <E : Event> waitForNextBlocking(key: Event.Key<E>, matcher: BlockingContinuousSessionEventMatcher<E>): E(source)

阻塞并等待下一个符合条件的事件对象。

Parameters

key

事件类型 Event.Key

matcher

匹配函数。相当于 (EventProcessingContext, Event) -> Boolean

Throws

如果超时

被终止

@JvmName(name = "waitingForNext")

fun <E : Event> waitForNextBlocking(id: String, key: Event.Key<E>, timeout: Long, timeUnit: TimeUnit, matcher: BlockingContinuousSessionEventMatcher<E> = BlockingContinuousSessionEventMatcher): E(source)

阻塞并等待下一个符合条件的事件对象。

Parameters

持续会话监听函数的唯一ID

key

事件类型 Event.Key

timeout

超时时间，大于0时生效。

timeUnit

timeout 时间单位

matcher

匹配函数。相当于 (EventProcessingContext, Event) -> Boolean

Throws

如果超时

被终止

@JvmName(name = "waitingForNext")

fun <E : Event> waitForNextBlocking(key: Event.Key<E>, timeout: Long, timeUnit: TimeUnit, matcher: BlockingContinuousSessionEventMatcher<E> = BlockingContinuousSessionEventMatcher): E(source)

阻塞并等待下一个符合条件的事件对象。

Parameters

key

事件类型 Event.Key

timeout

超时时间，大于0时生效。

timeUnit

timeout 时间单位

matcher

匹配函数。相当于 (EventProcessingContext, Event) -> Boolean

Throws

如果超时

被终止

@JvmName(name = "waitingForNext")

fun waitForNextBlocking(id: String, timeoutDuration: JavaDuration = JavaDuration.ZERO, matcher: BlockingContinuousSessionEventMatcher<Event> = BlockingContinuousSessionEventMatcher): Event(source)

阻塞并等待下一个符合条件的事件对象。

Parameters

持续会话监听函数的唯一ID

timeoutDuration

超时时间，大于0时生效。

matcher

匹配函数。相当于 (EventProcessingContext, Event) -> Boolean

Throws

如果超时

被终止

@JvmName(name = "waitingForNext")

fun waitForNextBlocking(timeoutDuration: JavaDuration = JavaDuration.ZERO, matcher: BlockingContinuousSessionEventMatcher<Event> = BlockingContinuousSessionEventMatcher): Event(source)

阻塞并等待下一个符合条件的事件对象。

Parameters

timeoutDuration

超时时间，大于0时生效。

matcher

匹配函数。相当于 (EventProcessingContext, Event) -> Boolean

Throws

如果超时

被终止

@JvmName(name = "waitingForNext")

fun waitForNextBlocking(id: String, timeout: Long, timeUnit: TimeUnit, matcher: BlockingContinuousSessionEventMatcher<Event> = BlockingContinuousSessionEventMatcher): Event(source)

阻塞并等待下一个符合条件的事件对象。

Parameters

持续会话监听函数的唯一ID

timeout

超时时间，大于0时生效。

timeUnit

timeout 时间单位

matcher

匹配函数。相当于 (EventProcessingContext, Event) -> Boolean

Throws

如果超时

被终止

@JvmName(name = "waitingForNext")

fun waitForNextBlocking(timeout: Long, timeUnit: TimeUnit, matcher: BlockingContinuousSessionEventMatcher<Event> = BlockingContinuousSessionEventMatcher): Event(source)

阻塞并等待下一个符合条件的事件对象。

Parameters

timeout

超时时间，大于0时生效。

timeUnit

timeout 时间单位

matcher

匹配函数。相当于 (EventProcessingContext, Event) -> Boolean

Throws

如果超时

被终止

@JvmName(name = "waitingForNext")

fun waitForNextBlocking(id: String = randomIdStr(), matcher: BlockingContinuousSessionEventMatcher<Event>): Event(source)

阻塞并等待下一个符合条件的事件对象。

Parameters

持续会话监听函数的唯一ID

matcher

匹配函数。相当于 (EventProcessingContext, Event) -> Boolean

Throws