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 © 20032015 The Apache Software Foundation.