public class FlowProgressHandleImpl<A> implements FlowProgressHandle<A>
Constructor and Description |
---|
FlowProgressHandleImpl(StateMachineRunId id,
CordaFuture<A> returnValue,
NonExistentClass progress,
DataFeed<java.lang.Integer,java.lang.Integer> stepsTreeIndexFeed,
DataFeed<? extends java.util.List<? extends error.NonExistentClass>,java.util.List> stepsTreeFeed) |
Modifier and Type | Method and Description |
---|---|
void |
close()
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.
|
StateMachineRunId |
component1()
The started state machine
|
CordaFuture<A> |
component2()
A
|
NonExistentClass |
component3()
The stream of progress tracker events.
|
DataFeed<java.lang.Integer,java.lang.Integer> |
component4()
|
DataFeed<java.util.List,java.util.List> |
component5()
|
FlowProgressHandleImpl<A> |
copy(StateMachineRunId id,
CordaFuture<A> returnValue,
NonExistentClass progress) |
FlowProgressHandleImpl<A> |
copy(StateMachineRunId id,
CordaFuture<A> returnValue,
NonExistentClass progress,
DataFeed<java.lang.Integer,java.lang.Integer> stepsTreeIndexFeed,
DataFeed<? extends java.util.List<? extends error.NonExistentClass>,java.util.List> stepsTreeFeed) |
boolean |
equals(java.lang.Object p) |
StateMachineRunId |
getId()
The started state machine
|
NonExistentClass |
getProgress()
The stream of progress tracker events.
|
CordaFuture<A> |
getReturnValue()
A
|
DataFeed<java.util.List,java.util.List> |
getStepsTreeFeed()
|
DataFeed<java.lang.Integer,java.lang.Integer> |
getStepsTreeIndexFeed()
|
int |
hashCode() |
java.lang.String |
toString() |
close, getProgress, getStepsTreeFeed, getStepsTreeIndexFeed
close, getId, getReturnValue
public FlowProgressHandleImpl(StateMachineRunId id, CordaFuture<A> returnValue, NonExistentClass progress, DataFeed<java.lang.Integer,java.lang.Integer> stepsTreeIndexFeed, DataFeed<? extends java.util.List<? extends error.NonExistentClass>,java.util.List> stepsTreeFeed)
id
- The started state machine's ID.returnValue
- A interface CordaFuture
of the flow's return value.progress
- The stream of progress tracker events.stepsTreeIndexFeed
- class DataFeed
of current step in the steps tree, see ProgressTrackerstepsTreeFeed
- class DataFeed
of current steps tree, see ProgressTrackerpublic FlowProgressHandleImpl<A> copy(StateMachineRunId id, CordaFuture<A> returnValue, NonExistentClass progress)
public void close()
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.
public StateMachineRunId getId()
The started state machine
's ID.
public CordaFuture<A> getReturnValue()
A
interface CordaFuture
of the flow's return value.
interface CordaFuture
public NonExistentClass getProgress()
The stream of progress tracker events.
public DataFeed<java.lang.Integer,java.lang.Integer> getStepsTreeIndexFeed()
of current step in the steps tree, see ProgressTracker
class DataFeed
,
ProgressTrackerpublic DataFeed<java.util.List,java.util.List> getStepsTreeFeed()
of current steps tree, see ProgressTracker
class DataFeed
,
ProgressTrackerpublic StateMachineRunId component1()
The started state machine
's ID.
public CordaFuture<A> component2()
A
interface CordaFuture
of the flow's return value.
interface CordaFuture
public NonExistentClass component3()
The stream of progress tracker events.
public DataFeed<java.lang.Integer,java.lang.Integer> component4()
of current step in the steps tree, see ProgressTracker
class DataFeed
,
ProgressTrackerpublic DataFeed<java.util.List,java.util.List> component5()
of current steps tree, see ProgressTracker
class DataFeed
,
ProgressTrackerpublic FlowProgressHandleImpl<A> copy(StateMachineRunId id, CordaFuture<A> returnValue, NonExistentClass progress, DataFeed<java.lang.Integer,java.lang.Integer> stepsTreeIndexFeed, DataFeed<? extends java.util.List<? extends error.NonExistentClass>,java.util.List> stepsTreeFeed)
public java.lang.String toString()
public int hashCode()
public boolean equals(java.lang.Object p)