data class FlowHandle<A>
FlowHandle is a serialisable handle for the started flow, parameterised by the type of the flow's return value.
id
- The started state machine's ID.
progress
- The stream of progress tracker events.
returnValue
- An Observable emitting a single event containing the flow's return value.
To block on this value:
val returnValue = rpc.startFlow(::MyFlow).returnValue.toBlocking().first()
<init> |
FlowHandle(id: StateMachineRunId, progress: Observable<String>, returnValue: Observable<A>)
FlowHandle is a serialisable handle for the started flow, parameterised by the type of the flow's return value. |
id |
val id: StateMachineRunId |
progress |
val progress: Observable<String> |
returnValue |
val returnValue: Observable<A> |