A
- B
- public interface ZippedFlow<A,B> extends FlowOperations<Tuple<A,B>,ZippedFlow<A,B>>
Flow.zipWith(Flow)
method (or created from a Map via F.zippedFlow(Map)
), a Flow of
combined Tuple
values (that can be deconstructed, eventually, using unzip()
).Modifier and Type | Method and Description |
---|---|
ZippedFlow<A,B> |
filterOnFirst(Predicate<? super A> predicate)
Filters the tuples in the zipped flow by applying a predicate to the first value in each tuple.
|
ZippedFlow<A,B> |
filterOnSecond(Predicate<? super B> predicate)
Filters the tuples in the zipped flow by applying a predicate to the second value in each tuple.
|
Flow<A> |
firsts()
Returns a flow of the first values of the tuples of the zipped flow.
|
<X,Y> ZippedFlow<X,Y> |
mapTuples(Mapper<Tuple<A,B>,Tuple<X,Y>> mapper)
Mapping for zipped flows; a mapper is used to map tuples of this zipped flow into new tuples
with a new type, forming the resulting zipped flow.
|
ZippedFlow<A,B> |
removeOnFirst(Predicate<? super A> predicate)
Removes tuples from the zipped flow by applying a predicate to the first value in each tuple.
|
ZippedFlow<A,B> |
removeOnSecond(Predicate<? super B> predicate)
Removes tuples from the zipped flow by applying a predicate to the second value in each tuple.
|
Flow<B> |
seconds()
Returns a flow of the second values of the tuples of the zipped flow.
|
Map<A,B> |
toMap()
Constructs a HashMap by converting the tuples of the zipped flow into keys (first tuple value) and values (second
tuple value).
|
Tuple<Flow<A>,Flow<B>> |
unzip()
A ZippedFlow is a Flow of Tuples; this inverts that, splitting each Tuple into
a Flow of elements, then assembling the result as a Tuple of two values.
|
<X,Y> ZippedFlow<X,Y> mapTuples(Mapper<Tuple<A,B>,Tuple<X,Y>> mapper)
Tuple<Flow<A>,Flow<B>> unzip()
Flow<A> firsts()
Flow<B> seconds()
ZippedFlow<A,B> filterOnFirst(Predicate<? super A> predicate)
ZippedFlow<A,B> filterOnSecond(Predicate<? super B> predicate)
ZippedFlow<A,B> removeOnFirst(Predicate<? super A> predicate)
ZippedFlow<A,B> removeOnSecond(Predicate<? super B> predicate)
${project.version} - Copyright © 2003-2015 The Apache Software Foundation.