summaryrefslogtreecommitdiff
path: root/base/src/main/java/bjc/utils/funcutils/ChainIterator.java
blob: 36f94e59c69c9548af4ed99e5a9973300399fbfb (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
package bjc.utils.funcutils;

import java.util.*;
import java.util.function.*;

/**
 * A chain iterator. This is essentially flatMap in iterator form.
 * 
 * @author bjculkin
 *
 * @param <T1>
 *             The type of the input values.
 *
 * @param <T2>
 *             The type of the output values.
 */
public class ChainIterator<T1, T2> implements Iterator<T2> {
	private Iterator<T1> mainItr;
	private Function<T1, Iterator<T2>> trans;

	private Iterator<T2> curItr;

	/**
	 * Create a new chain iterator.
	 *
	 * @param mainItr
	 *                The main iterator for input.
	 *
	 * @param trans
	 *                The transformation to use to produce the outputs.
	 */
	public ChainIterator(Iterator<T1> mainItr, Function<T1, Iterator<T2>> trans) {
		this.mainItr = mainItr;
		this.trans = trans;
	}

	@Override
	public boolean hasNext() {
		if (curItr != null) {
			return curItr.hasNext() ? true : mainItr.hasNext();
		}

		return mainItr.hasNext();
	}

	@Override
	public T2 next() {
		if (curItr == null || !curItr.hasNext()) {
			curItr = trans.apply(mainItr.next());
		}

		return curItr.next();
	}
}