data class FlowProgressHandleImpl<A> : FlowProgressHandle<A>
FlowProgressHandleImpl(id: StateMachineRunId, returnValue: CordaFuture<A>, progress: <ERROR CLASS><String>, stepsTreeIndexFeed: DataFeed<Int, Int>? = null, stepsTreeFeed: DataFeed<List<<ERROR CLASS><Int, String>>, List<<ERROR CLASS><Int, String>>>? = null) |
val id: StateMachineRunId
The started state machine's ID. |
|
val progress: <ERROR CLASS><String>
The stream of progress tracker events. |
|
val returnValue: CordaFuture<A>
A CordaFuture of the flow's return value. |
|
val stepsTreeFeed: DataFeed<List<<ERROR CLASS><Int, String>>, List<<ERROR CLASS><Int, String>>>?
DataFeed of current steps tree, see ProgressTracker |
|
val stepsTreeIndexFeed: DataFeed<Int, Int>?
DataFeed of current step in the steps tree, see ProgressTracker |
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 copy(id: StateMachineRunId, returnValue: CordaFuture<A>, progress: <ERROR CLASS><String>): FlowProgressHandleImpl<A> |
fun Any.contextLogger(): <ERROR CLASS>
When called from a companion object, returns the logger for the enclosing class. |