sdk-core/dev.restate.sdk.core/InvocationFlow/InvocationInputSubscriber

InvocationInputSubscriber

interface InvocationInputSubscriber : Flow.Subscriber<T>

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)