ContinuousSessionReceiver

持续会话的结果接收器,通过 ContinuousSessionContext.getReceiver 获取, 用于挂起并等待一个结果。

See also

Functions

Link copied to clipboard
abstract fun asFuture(): Future<T>

将当前这个 session 转化为 Future.

Link copied to clipboard
abstract suspend fun await(): T

获取或挂起等待结果。

Link copied to clipboard
abstract fun cancel(reason: Throwable? = null)

终止此会话。不会对终止状态进行检测。

Link copied to clipboard
open fun waiting(): T

阻塞的等待当前receiver得到结果或推送了异常。

open fun waiting(timeout: Long, timeUnit: TimeUnit): T

阻塞的等待当前receiver得到结果或推送了异常,如果在规定时间内未结束则抛出超时异常。