EndpointWiredRdTask

class EndpointWiredRdTask<TReq, TRes>(bindLifetime: Lifetime, call: RdCall<TReq, TRes>, rdid: RdId, wireScheduler: IScheduler) : WiredRdTask<TReq, TRes>

Constructors

constructor(bindLifetime: Lifetime, call: RdCall<TReq, TRes>, rdid: RdId, wireScheduler: IScheduler)

val lifetime: Lifetime

open override val location: RName

open override val protocol: IProtocol?

open override val rdid: RdId

open override val result: WriteOnceProperty<RdTaskResult<TRes>>

val wireScheduler: IScheduler

suspend fun <T> IRdTask<T>.~~await~~(): T

Callback that wire triggers when it receives messaged

fun set(v: TRes)

open override fun toString(): String

inline fun <T> IRdTask<T>.wait(timeoutMs: Long, pump: () -> Unit): Boolean