rd-framework/com.jetbrains.rd.framework.impl/WiredRdTask

WiredRdTask

abstract class WiredRdTask<TReq, TRes>(val call: RdCall<TReq, TRes>, val rdid: RdId, val wireScheduler: IScheduler) : RdTask<TRes> , IRdWireable

Inheritors

CallSiteWiredRdTask

EndpointWiredRdTask

Constructors

WiredRdTask

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

Properties

call

val call: RdCall<TReq, TRes>

isCanceled

val <T> IRdTask<T>.isCanceled: Boolean

isFaulted

val <T> IRdTask<T>.isFaulted: Boolean

isSucceeded

val <T> IRdTask<T>.isSucceeded: Boolean

location

open override val location: RName

protocol

open override val protocol: IProtocol?

protocolOrThrow

val IRdDynamic.protocolOrThrow: IProtocol

rdid

open override val rdid: RdId

result

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

serializationContext

open override val serializationContext: SerializationCtx?

wire

val wire: IWire?

wireScheduler

val wireScheduler: IScheduler

Functions

asCompletableFuture

fun <T> IRdTask<T>.asCompletableFuture(): CompletableFuture<T>

await

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

onWireReceived

open override fun onWireReceived(buffer: AbstractBuffer, dispatchHelper: IRdWireableDispatchHelper)

Callback that wire triggers when it receives messaged

abstract fun onWireReceived(proto: IProtocol, ctx: SerializationCtx, buffer: AbstractBuffer, dispatchHelper: IRdWireableDispatchHelper)

set

fun set(v: TRes)

fun set(e: Throwable)

toString

open override fun toString(): String

wait

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