Class ProcessingService.CallableMapper<W,​R>

  • All Implemented Interfaces:
    java.util.concurrent.Callable<TwoStepMapper<W,​R>>
    Enclosing class:
    ProcessingService

    static final class ProcessingService.CallableMapper<W,​R>
    extends java.lang.Object
    implements java.util.concurrent.Callable<TwoStepMapper<W,​R>>
    • Field Detail

      • myWork

        private final java.util.Queue<W> myWork
    • Constructor Detail

      • CallableMapper

        CallableMapper​(java.util.Queue<W> work,
                       TwoStepMapper<W,​R> mapper)
    • Method Detail

      • call

        public TwoStepMapper<W,​R> call()
                                      throws java.lang.Exception
        Specified by:
        call in interface java.util.concurrent.Callable<W>
        Throws:
        java.lang.Exception