ksrpc-core/com.monkopedia.ksrpc/Transformer

Transformer

Adapts a user-facing type to the wire-level CallData representation. Only non-error variants flow through transformers — CallData.Error frames are intercepted by RpcMethod.callChannel and converted to a thrown Throwable via RpcMethod.decodeError before any transformer sees them.

Inheritors

ResultTransformer

SerializerTransformer

BinaryTransformer

BaseSubserviceTransformer

Properties

hasContent

open val hasContent: Boolean

Functions

transform

abstract suspend fun <S> transform(input: T, channel: SerializedService<S>): CallData<S>

transformOutcome

open suspend fun <S> transformOutcome(output: T, channel: SerializedService<S>, encodeError: (Throwable) -> CallData.Error<S>): CallData<S>

Server-side boundary hook (issue #133). Invoked by RpcMethod.call with the value returned by the handler. The default implementation simply delegates to transform; transformers that need to observe the failure channel (e.g. ResultTransformer for Result<O> return types) override this to fold a returned failure into the wire-level error frame via encodeError.

untransform

abstract suspend fun <S> untransform(data: CallData<S>, channel: SerializedService<S>): T

untransformOutcome

open suspend fun <S> untransformOutcome(data: CallData<S>, channel: SerializedService<S>, decodeError: (CallData.Error<S>) -> Throwable): T

Client-side boundary hook (issue #133). Invoked by RpcMethod.callChannel with the raw wire response (which may be a CallData.Error). The default implementation throws the decoded error — preserving today's behaviour — and otherwise delegates to untransform. ResultTransformer overrides this to wrap the outcome in a kotlin.Result instead of throwing.