Class BatchNode.TwoStepWrapper<T>

  • All Implemented Interfaces:
    TwoStepMapper<T,​java.lang.Boolean>
    Enclosing class:
    BatchNode<T>

    private static final class BatchNode.TwoStepWrapper<T>
    extends java.lang.Object
    implements TwoStepMapper<T,​java.lang.Boolean>
    • Field Detail

      • myActualConsumer

        private final java.util.function.Consumer<T> myActualConsumer
    • Constructor Detail

      • TwoStepWrapper

        TwoStepWrapper​(java.util.function.Supplier<java.util.function.Consumer<T>> consumerFactory)
    • Method Detail

      • consume

        public void consume​(T item)
        Description copied from interface: TwoStepMapper
        Input/consume the items that should be mapped
        Specified by:
        consume in interface TwoStepMapper<T,​java.lang.Boolean>
      • getResults

        public java.lang.Boolean getResults()
        Description copied from interface: TwoStepMapper
        Output the mapped results
        Specified by:
        getResults in interface TwoStepMapper<T,​java.lang.Boolean>
      • reset

        public void reset()
        Description copied from interface: TwoStepMapper
        Reset, so it can be re-used
        Specified by:
        reset in interface TwoStepMapper<T,​java.lang.Boolean>