waitForNextBlocking

@JvmName(name = "waitingForNext")
fun <E : Event> waitForNextBlocking(id: String, key: Event.Key<E>, timeoutDuration: JavaDuration = JavaDuration.ZERO, matcher: BlockingContinuousSessionEventMatcher<E> = BlockingContinuousSessionEventMatcher): E

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

See also

Parameters

id

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

key

事件类型 Event.Key

timeoutDuration

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

matcher

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

Throws

TimeoutCancellationException

如果超时

CancellationException

被终止


@JvmName(name = "waitingForNext")
fun <E : Event> waitForNextBlocking(id: String, key: Event.Key<E>, matcher: BlockingContinuousSessionEventMatcher<E>): E

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

See also

Parameters

id

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

key

事件类型 Event.Key

matcher

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

Throws

TimeoutCancellationException

如果超时

CancellationException

被终止


@JvmName(name = "waitingForNext")
fun <E : Event> waitForNextBlocking(key: Event.Key<E>, timeoutDuration: JavaDuration = JavaDuration.ZERO, matcher: BlockingContinuousSessionEventMatcher<E> = BlockingContinuousSessionEventMatcher): E

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

See also

Parameters

key

事件类型 Event.Key

timeoutDuration

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

matcher

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

Throws

TimeoutCancellationException

如果超时

CancellationException

被终止


@JvmName(name = "waitingForNext")
fun <E : Event> waitForNextBlocking(key: Event.Key<E>, matcher: BlockingContinuousSessionEventMatcher<E>): E

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

See also

Parameters

key

事件类型 Event.Key

matcher

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

Throws

TimeoutCancellationException

如果超时

CancellationException

被终止


@JvmName(name = "waitingForNext")
fun <E : Event> waitForNextBlocking(id: String, key: Event.Key<E>, timeout: Long, timeUnit: TimeUnit, matcher: BlockingContinuousSessionEventMatcher<E> = BlockingContinuousSessionEventMatcher): E

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

See also

Parameters

id

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

key

事件类型 Event.Key

timeout

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

timeUnit

timeout 时间单位

matcher

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

Throws

TimeoutCancellationException

如果超时

CancellationException

被终止


@JvmName(name = "waitingForNext")
fun <E : Event> waitForNextBlocking(key: Event.Key<E>, timeout: Long, timeUnit: TimeUnit, matcher: BlockingContinuousSessionEventMatcher<E> = BlockingContinuousSessionEventMatcher): E

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

See also

Parameters

key

事件类型 Event.Key

timeout

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

timeUnit

timeout 时间单位

matcher

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

Throws

TimeoutCancellationException

如果超时

CancellationException

被终止


@JvmName(name = "waitingForNext")
fun waitForNextBlocking(id: String, timeoutDuration: JavaDuration = JavaDuration.ZERO, matcher: BlockingContinuousSessionEventMatcher<Event> = BlockingContinuousSessionEventMatcher): Event

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

See also

Parameters

id

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

timeoutDuration

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

matcher

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

Throws

TimeoutCancellationException

如果超时

CancellationException

被终止


@JvmName(name = "waitingForNext")
fun waitForNextBlocking(timeoutDuration: JavaDuration = JavaDuration.ZERO, matcher: BlockingContinuousSessionEventMatcher<Event> = BlockingContinuousSessionEventMatcher): Event

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

See also

Parameters

timeoutDuration

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

matcher

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

Throws

TimeoutCancellationException

如果超时

CancellationException

被终止


@JvmName(name = "waitingForNext")
fun waitForNextBlocking(id: String, timeout: Long, timeUnit: TimeUnit, matcher: BlockingContinuousSessionEventMatcher<Event> = BlockingContinuousSessionEventMatcher): Event

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

See also

Parameters

id

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

timeout

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

timeUnit

timeout 时间单位

matcher

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

Throws

TimeoutCancellationException

如果超时

CancellationException

被终止


@JvmName(name = "waitingForNext")
fun waitForNextBlocking(timeout: Long, timeUnit: TimeUnit, matcher: BlockingContinuousSessionEventMatcher<Event> = BlockingContinuousSessionEventMatcher): Event

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

See also

Parameters

timeout

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

timeUnit

timeout 时间单位

matcher

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

Throws

TimeoutCancellationException

如果超时

CancellationException

被终止


@JvmName(name = "waitingForNext")
fun waitForNextBlocking(id: String = randomIdStr(), matcher: BlockingContinuousSessionEventMatcher<Event>): Event

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

See also

Parameters

id

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

matcher

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

Throws

CancellationException

被终止