sdk-api-kotlin/dev.restate.sdk.kotlin/HandlerRunner

HandlerRunner

class HandlerRunner<REQ, RES, CTX : Context> : HandlerRunner<REQ, RES>

Adapter class for dev.restate.sdk.endpoint.definition.HandlerRunner to use the Kotlin API.

Types

Link copied to clipboard
object Companion
Link copied to clipboard
class Options(var coroutineContext: CoroutineContext = Dispatchers.Default, var handlerInterceptorFactories: MutableList<HandlerInterceptor.Factory> = SPI_HANDLER_FACTORIES.toMutableList(), var runInterceptorFactories: MutableList<RunInterceptor.Factory> = SPI_RUN_FACTORIES.toMutableList()) : HandlerRunner.Options

dev.restate.sdk.kotlin.HandlerRunner options. You can override the default options to configure the CoroutineContext to run the handler, and to register interceptor factories.

Functions

Link copied to clipboard
open override fun run(handlerContext: HandlerContext, requestSerde: Serde<REQ>, responseSerde: Serde<RES>, onClosedInvocationStreamHook: AtomicReference<Runnable>): CompletableFuture<Slice>