Class CompositeStateful<T,​IN,​OUT>

  • All Implemented Interfaces:
    Stateful<OUT>

    public class CompositeStateful<T,​IN,​OUT>
    extends Object
    implements Stateful<OUT>
    Represents a stateful component of one or more individual stateful elements.
    • Method Detail

      • create

        public static <T,​IN,​OUT> CompositeStateful<T,​IN,​OUT> create​(OUT initialState,
                                                                                            Function<Collection<IN>,​OUT> transformer,
                                                                                            BiConsumer<OUT,​OUT> beforeTransitionCallback)
        Creates a new transformer with an initial state and the transform function that should be applied.
        Parameters:
        initialState - the initial state.
        transformer - the custom transformer for the states.
        Returns:
        a created stateful composite.
      • create

        public static <T,​IN,​OUT> CompositeStateful<T,​IN,​OUT> create​(OUT initialState,
                                                                                            Function<Collection<IN>,​OUT> transformer)
        Creates a new transformer with an initial state and the transform function that should be applied.
        Parameters:
        initialState - the initial state.
        transformer - the custom transformer for the states.
        Returns:
        a created stateful composite.
      • register

        public void register​(T identifier,
                             Stateful<IN> upstream)
        Registers a stateful element with the composite.
        Parameters:
        identifier - the unique identifier to use.
        upstream - the upstream flux with the state stream.
      • deregister

        public void deregister​(T identifier)
        Deregisters a stateful element from the composite.

        Note that it might be possible that the passed in identifier is already deregistered (for example if the upstream flux already completed or failed). In this case, this is essentially a "noop" since the target state, the identifier not being part of the stateful component, is already reached.

        Parameters:
        identifier - the unique identifier to use.
      • close

        public void close()
        Closes the composite permanently and deregisters all elements.
      • state

        public OUT state()
        Description copied from interface: Stateful
        Returns the current state of the stateful component.
        Specified by:
        state in interface Stateful<T>
      • states

        public Flux<OUT> states()
        Description copied from interface: Stateful
        Returns a stream of states for this component as they change.
        Specified by:
        states in interface Stateful<T>