Class ShardedConsumer<T>

    • Field Detail

      • myConsumers

        private final java.util.function.Consumer<T>[] myConsumers
    • Constructor Detail

      • ShardedConsumer

        ShardedConsumer​(java.util.function.Consumer<T>[] consumers)
    • Method Detail

      • of

        static <T> ShardedConsumer<T> of​(java.util.function.ToIntFunction<T> distributor,
                                         java.util.function.Consumer<T>[] consumers)
      • close

        public void close()
                   throws java.lang.Exception
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface AutoConsumer<T>
        Throws:
        java.lang.Exception