docs/net.corda.core.internal/WaitForStateConsumption

WaitForStateConsumption

class WaitForStateConsumption(val stateRefs: Set<StateRef>, val services: ServiceHub) : FlowAsyncOperation<Unit>

An FlowAsyncOperation which suspends a flow until the provided StateRefs have been updated.

WARNING! Remember that if the node isn't aware of the supplied StateRefs or if the StateRefs are never updated, then the calling flow will remain suspended.

Constructors

constructor(stateRefs: Set<StateRef>, services: ServiceHub)

Types

Companion

object Companion

Properties

externalOperationImplName

val FlowAsyncOperation<*>.externalOperationImplName: String

Returns a name of the external operation implementation considering that it can wrapped by WrappedFlowExternalAsyncOperation or WrappedFlowExternalOperation

services

val services: ServiceHub

a ServiceHub instance

stateRefs

val stateRefs: Set<StateRef>

the StateRefs which will be updated.

Functions

execute

open override fun execute(deduplicationId: String): CordaFuture<Unit>

Performs the operation in a non-blocking fashion.