Calls consumer for each index and value
@param consumer
335725
public void forEach(IntBiConsumer consumer)
    {
        int len = length();
        for (int ii=0;ii<len;ii++)
        {
            consumer.accept(ii, get(ii));
        }
    }
1308466
public static void loopFor(int start , int endExclusive , IntConsumer consumer ) {
		try {
			pool.submit(() ->IntStream.range(start, endExclusive).parallel().forEach(consumer)).get();
		} catch (InterruptedException | ExecutionException e) {
			e.printStackTrace();
		}
	}
1373944
@SafeVarargs
    public final ServerListenerBuilder addStartingCallbacks(Consumer<? super Server>... consumers) {
        return addStartingCallbacks(Arrays.asList(consumers));
    }
728023
synchronized void add(ConsumerSessionImpl consumer)
  {
    consumer.setId(_consumerCount);
    
    if (tc.isEntryEnabled())
      SibTr.entry(tc, "add", new Long(consumer.getIdInternal()) );

    _consumers.put(new Long(_consumerCount), consumer);

    _consumerCount++;

    if (tc.isEntryEnabled())
      SibTr.exit(tc, "add");
  }
1329979
protected final void registerConsumer( AbstractMessageConsumer consumer )
    {
        if (consumersMap.put(consumer.getId(),consumer) != null)
        	throw new IllegalArgumentException("Consumer "+consumer.getId()+" already exists");
    }
34301
public static final <T> void doFor(Object bean, String property, Consumer<T> consumer)
    {
        T t = (T) getValue(bean, property);
        consumer.accept(t);
    }
134728
public static void consumePathList(List<Path> pathList,
			Consumer<Path> consumer) {
		for (Path path : pathList)
			consumer.accept(path);
	}
1093337
private void withMap(Consumer<RMap<String, String>> consumer) {
        final RMap<String, String> map = client.getMap(prefix);
        consumer.accept(map);
    }
739158
public static <T> void consumeIfTrue(boolean bool, T target,
            Consumer<T> consumer) {
        if (bool)
            consumer.accept(target);
    }
949582
@Override
    public void accept(E value) {
        for (Consumer<E> consumer : consumers) {
            consumer.accept(value);
        }
    }
9183
private void _checkAndSubscribe(KafkaConsumer<?, ?> consumer, String topic) {
        synchronized (consumer) {
            Set<String> subscription = consumer.subscription();
            if (subscription == null || !subscription.contains(topic)) {
                consumer.subscribe(Arrays.asList(topic));
            }
        }
    }
570805
public static <T> Runnable curry(Consumer<T> consumer, T value) {
        dbc.precondition(consumer != null, "cannot bind parameter of a null consumer");
        return () -> consumer.accept(value);
    }
329920
public void produceResults(Consumer<T> consumer, ProducerContext context) {
    consumer.onNewResult((T) null, Consumer.IS_LAST);
  }
583895
@SafeVarargs
    public final ServerListenerBuilder addStartedCallbacks(Consumer<? super Server>... consumers) {
        return addStartedCallbacks(Arrays.asList(consumers));
    }
40243
void addConsumer(ConsumerSessionImpl consumer) {
        if (TraceComponent.isAnyTracingEnabled()
            && tc.isEntryEnabled())
            SibTr.entry(tc, "addConsumer", consumer);

        _consumerList.add(consumer);

        if (TraceComponent.isAnyTracingEnabled()
            && tc.isEntryEnabled())
            SibTr.exit(tc, "addConsumer");
    }
339702
public void readAll (@Nonnull final Consumer <? super ICommonsList <String>> aLineConsumer) throws IOException
  {
    while (m_bHasNext)
    {
      final ICommonsList <String> aNextLineAsTokens = readNext ();
      if (aNextLineAsTokens != null)
        aLineConsumer.accept (aNextLineAsTokens);
    }
  }
705443
public void each(Consumer<T> operation) {
		for (T component : components) {
			operation.accept(component);
		}
	}