interface FlowProgressHandle<A> : FlowHandle<A>
FlowProgressHandle is a serialisable handle for the started flow, parameterised by the type of the flow's return value.
abstract val progress: <ERROR CLASS><String>
The stream of progress tracker events. |
|
abstract val stepsTreeFeed: DataFeed<List<<ERROR CLASS><Int, String>>, List<<ERROR CLASS><Int, String>>>?
DataFeed of current steps tree, see ProgressTracker |
|
abstract val stepsTreeIndexFeed: DataFeed<Int, Int>?
DataFeed of current step in the steps tree, see ProgressTracker |
abstract val id: StateMachineRunId
The started state machine's ID. |
|
abstract val returnValue: CordaFuture<A>
A CordaFuture of the flow's return value. |
abstract fun close(): Unit
Use this function for flows whose returnValue and progress are not going to be used or tracked, so as to free up server resources. Note that it won't really close if one subscribes on progress Observable, but then forgets to unsubscribe. |
fun Any.contextLogger(): <ERROR CLASS>
When called from a companion object, returns the logger for the enclosing class. |
data class FlowProgressHandleImpl<A> : FlowProgressHandle<A> |