sdk-core/dev.restate.sdk.core/ResolvedEndpointHandler

ResolvedEndpointHandler

interface ResolvedEndpointHandler : Flow.Processor<T, R>

Resolved handler for an invocation.

Functions

Link copied to clipboard
abstract fun onComplete()
Link copied to clipboard
abstract fun onError(p: Throwable)
Link copied to clipboard
abstract fun onNext(p: T)
Link copied to clipboard
abstract fun onSubscribe(p: Flow.Subscription)
Link copied to clipboard
abstract fun responseContentType(): String
Link copied to clipboard
abstract fun subscribe(p: Flow.Subscriber<in T>)