public class FlowHandle<A>
class FlowHandle
is a serialisable handle for the started flow, parameterised by the type of the flow's return value.
class FlowHandle
Constructor and Description |
---|
FlowHandle(StateMachineRunId id,
rx.Observable<java.lang.String> progress,
rx.Observable<A> returnValue)
class FlowHandle is a serialisable handle for the started flow, parameterised by the type of the flow's return value. |
Modifier and Type | Method and Description |
---|---|
StateMachineRunId |
component1() |
rx.Observable<java.lang.String> |
component2() |
rx.Observable<A> |
component3() |
FlowHandle<A> |
copy(StateMachineRunId id,
rx.Observable<java.lang.String> progress,
rx.Observable<A> returnValue)
class FlowHandle is a serialisable handle for the started flow, parameterised by the type of the flow's return value. |
boolean |
equals(java.lang.Object p) |
StateMachineRunId |
getId() |
rx.Observable<java.lang.String> |
getProgress() |
rx.Observable<A> |
getReturnValue() |
int |
hashCode() |
java.lang.String |
toString() |
public FlowHandle(StateMachineRunId id, rx.Observable<java.lang.String> progress, rx.Observable<A> returnValue)
class 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()class FlowHandle
public StateMachineRunId getId()
public rx.Observable<java.lang.String> getProgress()
public rx.Observable<A> getReturnValue()
public StateMachineRunId component1()
public rx.Observable<java.lang.String> component2()
public rx.Observable<A> component3()
public FlowHandle<A> copy(StateMachineRunId id, rx.Observable<java.lang.String> progress, rx.Observable<A> returnValue)
class 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()class FlowHandle
public java.lang.String toString()
public int hashCode()
public boolean equals(java.lang.Object p)