corda / net.corda.core.messaging / FlowHandle / <init>

<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.

Parameters

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()