Class ShardedConsumer.GeneralShardedConsumer<T>

    • Field Detail

      • myConsumers

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

        private final java.util.function.ToIntFunction<T> myDistributor
      • myNumberOfShards

        private final int myNumberOfShards
    • Constructor Detail

      • GeneralShardedConsumer

        GeneralShardedConsumer​(java.util.function.ToIntFunction<T> distributor,
                               java.util.function.Consumer<T>[] consumers)
    • Method Detail

      • write

        public void write​(T item)
        Description copied from interface: AutoConsumer
        Write the item to the consumer.
        Parameters:
        item - The item to be written