sdk-core/dev.restate.sdk.core/RequestProcessor

RequestProcessor

interface RequestProcessor : Flow.Processor<T, R>

Resolved handler for an invocation. See Endpoint for more details.

Functions

abstract fun onComplete()

abstract fun onError(p: Throwable)

abstract fun onNext(p: T)

abstract fun onSubscribe(p: Flow.Subscription)

responseContentType

abstract fun responseContentType(): String

abstract fun statusCode(): Int

abstract fun subscribe(p: Flow.Subscriber<in T>)