本文整理了Java中java.util.stream.IntStream.iterate()
方法的一些代码示例,展示了IntStream.iterate()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。IntStream.iterate()
方法的具体详情如下:
包路径:java.util.stream.IntStream
类名称:IntStream
方法名:iterate
暂无
代码示例来源:origin: shekhargulati/99-problems
public static <T> List<T> reverse_IntStream(List<T> list) {
if (list == null) {
throw new IllegalArgumentException("list can't be null");
}
int size = list.size();
return IntStream.iterate(size - 1, el -> el - 1).limit(size).mapToObj(list::get).collect(toList());
}
代码示例来源:origin: biezhi/30-seconds-of-java8
/**
* Chunks an array into smaller arrays of a specified size.
*
* @param numbers Input array of numbers
* @param size The chunk size
* @return Smaller chunks
*/
public static int[][] chunk(int[] numbers, int size) {
return IntStream.iterate(0, i -> i + size)
.limit((long) Math.ceil((double) numbers.length / size))
.mapToObj(cur -> Arrays.copyOfRange(numbers, cur, cur + size > numbers.length ? numbers.length : cur + size))
.toArray(int[][]::new);
}
代码示例来源:origin: shekhargulati/strman-java
public static String[] chop(String input, int step) {
if (input == null || input.length() == 0) {
return EMPTY_ARRAY;
}
if (step == 0) {
return new String[]{input};
}
int strLength = input.length();
int iterations = strLength % step == 0 ? strLength / step : strLength / step + 1;
return IntStream.iterate(0, i -> i + step)
.limit(iterations)
.mapToObj(i -> input.substring(i, (i + step) < strLength ? i + step : strLength))
.toArray(String[]::new);
}
代码示例来源:origin: biezhi/30-seconds-of-java8
/**
* Find last index of element in the array. Return -1 in case element does not exist.
* <p>
* Uses IntStream.iterate().limit().filter() to find index of the element in the array.
*
* @param elements input array
* @param el element to find
* @return index of the element
*/
public static int lastIndexOf(int[] elements, int el) {
return IntStream.iterate(elements.length - 1, i -> i - 1)
.limit(elements.length)
.filter(idx -> elements[idx] == el)
.findFirst()
.orElse(-1);
}
代码示例来源:origin: apache/ignite
/** */
private static int keyInSamePartition(Ignite ignite, String cacheName, int key) {
Affinity<Object> affinity = ignite.affinity(cacheName);
return IntStream.iterate(key + 1, i -> i + 1)
.filter(i -> affinity.partition(i) == affinity.partition(key))
.findFirst().getAsInt();
}
代码示例来源:origin: apache/ignite
/** */
private static int keyInDifferentPartition(Ignite ignite, String cacheName, int key) {
Affinity<Object> affinity = ignite.affinity(cacheName);
return IntStream.iterate(key + 1, i -> i + 1)
.filter(i -> affinity.partition(i) != affinity.partition(key))
.findFirst().getAsInt();
}
}
代码示例来源:origin: prestodb/presto
@Test
public void testMassive()
{
BlockBuilder inputBlockBuilder = BIGINT.createBlockBuilder(null, 5000);
TypedHistogram typedHistogram = new SingleTypedHistogram(BIGINT, 1000);
IntStream.range(1, 2000)
.flatMap(i -> IntStream.iterate(i, IntUnaryOperator.identity()).limit(i))
.forEach(j -> BIGINT.writeLong(inputBlockBuilder, j));
Block inputBlock = inputBlockBuilder.build();
for (int i = 0; i < inputBlock.getPositionCount(); i++) {
typedHistogram.add(i, inputBlock, 1);
}
MapType mapType = mapType(BIGINT, BIGINT);
BlockBuilder out = mapType.createBlockBuilder(null, 1);
typedHistogram.serialize(out);
Block outputBlock = mapType.getObject(out, 0);
for (int i = 0; i < outputBlock.getPositionCount(); i += 2) {
assertEquals(BIGINT.getLong(outputBlock, i + 1), BIGINT.getLong(outputBlock, i));
}
}
}
代码示例来源:origin: shekhargulati/30-seconds-of-java
/**
* Chunks an array into smaller arrays of a specified size.
*
* @param numbers Input array of numbers
* @param size The chunk size
* @return Smaller chunks
*/
public static int[][] chunk(int[] numbers, int size) {
return IntStream.iterate(0, i -> i + size)
.limit((long) Math.ceil((double) numbers.length / size))
.mapToObj(cur -> Arrays.copyOfRange(numbers, cur, cur + size > numbers.length ? numbers.length : cur + size))
.toArray(int[][]::new);
}
代码示例来源:origin: shekhargulati/30-seconds-of-java
/**
* Find last index of element in the array. Return -1 in case element does not exist.
* <p>
* Uses IntStream.iterate().limit().filter() to find index of the element in the array.
*
* @param elements input array
* @param el element to find
* @return index of the element
*/
public static int lastIndexOf(int[] elements, int el) {
return IntStream.iterate(elements.length - 1, i -> i - 1)
.limit(elements.length)
.filter(idx -> elements[idx] == el)
.findFirst()
.orElse(-1);
}
代码示例来源:origin: poetix/protonpack
/**
* Cycles through a set of items indefinitely.
* @param items The items to cycle through.
* @param <T> The type of the items.
* @return An infinite stream cycling through the supplied items.
*/
public static <T> Stream<T> cycle(T...items) {
return IntStream.iterate(0, i -> i == items.length - 1 ? 0 : i + 1).mapToObj(i -> items[i]);
}
代码示例来源:origin: cmeza20/spring-data-generator
private static void br(int iterate) {
IntStream.iterate(0, i -> i++).limit(iterate).forEach(j ->{
if (mavenLogger == null) {
commonsLogger.info(StringUtils.EMPTY);
return;
}
mavenLogger.info(StringUtils.EMPTY);
});
}
代码示例来源:origin: yandex/yoctodb
@NotNull
@Override
public Iterator<IntToIntArray> ascending(
@NotNull
final BitSet valueFilter) {
final ArrayBitSet bs = LongArrayBitSet.zero(valueFilter.getSize());
return IntStream.iterate(0, i -> i + 1)
.mapToObj(i -> getIntToIntArray(valueFilter, bs, i))
.limit(keysCount)
.iterator();
}
代码示例来源:origin: yandex/yoctodb
@NotNull
@Override
public Iterator<IntToIntArray> ascending(
@NotNull
final BitSet valueFilter) {
final ArrayBitSet bs = LongArrayBitSet.zero(valueFilter.getSize());
return IntStream.iterate(0, i -> i + 1)
.mapToObj(i -> getIntToIntArray(valueFilter, bs, i))
.limit(keysCount)
.iterator();
}
代码示例来源:origin: kousen/java_8_recipes
public int nextPrime(int num) {
OptionalInt optionalInt = IntStream.iterate(num + 1, n -> n + 1)
.filter(this::isPrime)
.findFirst();
return optionalInt.orElseThrow(IllegalArgumentException::new);
}
}
代码示例来源:origin: geosdi/geo-platform
/**
* @return {@link IGPMessageKeyValue}
* @throws Exception
*/
@Override
public IGPMessageKeyValue[] build() throws Exception {
this.checkArguments();
return IntStream.iterate(0, n -> n + 1)
.limit(this.key.length)
.boxed().map(n -> new GPMessageKeyValue(key[n], value[n]))
.toArray(GPMessageKeyValue[]::new);
}
代码示例来源:origin: qaprosoft/zafira
public List<UserType> createUsers(int count) {
List<UserType> userTypes = new ArrayList<>();
IntStream.iterate(0, i -> i++).limit(count).forEach(index -> userTypes.add(createUser(new UserTypeBuilder())));
return userTypes;
}
}
代码示例来源:origin: aruld/java-oneliners
public static void main(String[] args) {
// Range is half-open (exclusive) as in Python, unlike Scala.
range(1, 1000).sum();
range(1, 1000).reduce(0, Integer::sum);
Stream.iterate(0, i -> i + 1).limit(1000).reduce(0, Integer::sum);
IntStream.iterate(0, i -> i + 1).limit(1000).reduce(0, Integer::sum);
}
代码示例来源:origin: jlink/jqwik
private Stream<String> fizzBuzz() {
return IntStream.iterate(1, i -> i + 1).mapToObj(i -> {
boolean divBy3 = i % 3 == 0;
boolean divBy5 = i % 5 == 0;
return divBy3 && divBy5 ? "FizzBuzz" : divBy3 ? "Fizz" : divBy5 ? "Buzz" : Integer.toString(i);
});
}
代码示例来源:origin: stackoverflow.com
package com.company;
import rx.Observable;
import java.util.function.IntPredicate;
import java.util.stream.IntStream;
public class Main {
public static void main(String[] args) {
final IntPredicate[] p={(x)->true};
IntStream primesStream=IntStream.iterate(2,n->n+1).filter(i -> p[0].test(i)).peek(i->p[0]=p[0].and(v->v%i!=0) );
Observable primes = Observable.from(()->primesStream.iterator());
primes.take(10).forEach((x) -> System.out.println(x.toString()));
}
}
代码示例来源:origin: org.infinispan/infinispan-core
private Object[] getKeys(boolean isOwner, int num) {
return IntStream.iterate(0, i -> i + 1)
.mapToObj(i -> "key" + i)
.filter(k -> cache(0, DIST).getAdvancedCache().getDistributionManager().getLocality(k).isLocal() == isOwner)
.limit(num).toArray(Object[]::new);
}
}
内容来源于网络,如有侵权,请联系作者删除!