Interface WorkflowSystem.SharedData<T,​Y>

  • Type Parameters:
    T - data type
    Enclosing interface:
    WorkflowSystem<P>

    public static interface WorkflowSystem.SharedData<T,​Y>
    Manages shared data, consumes results of operations, and produces input for subsequent operations
    • Method Detail

      • addData

        void addData​(T item)
        Add a data item
        Parameters:
        item -
      • produceNext

        T produceNext()
        produce a data item for input to a subsequent operation
        Returns:
      • produceState

        Y produceState()
        Produce wf state data from the shared data
      • with

        static <T,​Y> WorkflowSystem.SharedData<T,​Y> with​(java.util.function.Consumer<T> adder,
                                                                     java.util.function.Supplier<T> producer,
                                                                     java.util.function.Supplier<Y> stateProducer)