Is there a way in Java to apply a function to all the elements of a Stream
without breaking the Stream
chain? I know I can call forEach
, but that method returns a void
, not a Stream
.
7 Answers
There are (at least) 3 ways. For the sake of example code, I've assumed you want to call 2 consumer methods methodA
and methodB
:
A. Use peek()
:
list.stream().peek(x -> methodA(x)).forEach(x -> methodB(x));
Although the docs say only use it for "debug", it works (and it's in production right now)
B. Use map()
to call methodA, then return the element back to the stream:
list.stream().map(x -> {method1(x); return x;}).forEach(x -> methodB(x));
This is probably the most "acceptable" approach.
C. Do two things in the forEach()
:
list.stream().forEach(x -> {method1(x); methodB(x);});
This is the least flexible and may not suit your need.
-
3The implications of performing an action with side effects in
map
’s function and usingpeek
for such a (non-debug) side effect, are basically the same.– HolgerMay 8, 2017 at 8:28 -
3The invocation of
method1(x);
would be entirely useless, if it hadn’t side effects.– HolgerMay 8, 2017 at 16:43 -
3@holger incorrect. Method1 may do something with it, without mutation. I have actually used this exact pattern (the
peek()
version) when I wanted to collect the elements (to a Set, not timing critical, ie no problem) partway through a stream but also send the tail of the stream to a consumer via forEach(). Not useless.– Bohemian ♦May 8, 2017 at 17:55 -
3@holger A "side effect" a state change that is unadvertised and/or unexpected. Obviously a Set is mutated by adding to it, but that's expected, so it's not a "side effect". If the consumer mutated the element without advertising it, that would be a side effect. You seem tot be saying that if "something changes" when you invoke a method then it has a side effect, but that is nonsense. If a method is supposed to change something, then it's not a side effect; it's expected behavior.– Bohemian ♦May 8, 2017 at 19:39
-
9Your definition of “side effect” does not match the definition of the rest of the IT world. That’s especially dangerous, as API documentations, like that of the Stream API, discouraging side effects in functions, are referring to the standard definition, e.g. Wikipedia: “In computer science, a function or expression is said to have a side effect if it modifies some state outside its scope or has an observable interaction with its calling functions or the outside world”. It is irrelevant whether it is intentional or unexpected.– HolgerMay 9, 2017 at 8:08
You are looking for the Stream
's map()
function.
example:
List<String> strings = stream
.map(Object::toString)
.collect(ArrayList::new, ArrayList::add, ArrayList::addAll);
-
1If I use a map, I'll have to use multiple lines. something like myStream.map(obj -> {obj.foo(); return obj;}). I was wondering if there is a one line solution to that. May 6, 2017 at 0:01
-
-
12Map is not the correct place to take action on the element of the stream, it is for "converting" an item to something else.– Josh M.Jun 15, 2018 at 13:04
The best option you have is to apply the map to your stream. which returns a stream consisting of the results of applying the given function to the elements of the stream. For example:
IntStream.range(1, 100)
.boxed()
.map(item->item+3)
.map(item->item*2)...
We are applying several modifications to the stream but in some case we don't want to modify the stream. We just want to visit every element and then pass it down the stream without modification (like the peek() method in the streams API). in such cases, we can
StreamItem peekyMethod(StreamItem streamItemX) {
// .... visit the streamItemX
//Then pass it down the stream
return streamItemX;
}
Not entirely sure what you mean by breaking the stream chain
, but any operation on a Stream
that returns a Stream
will not break or consume your Stream. Streams are consumed by terminal operations
and as you noted the forEach
does not return a Stream<T>
and as such ends the stream, by executing all the intermediate
operations before the forEach and the forEach itself.
In the example that you provided in the comments:
myStream.map(obj -> {obj.foo(); return obj;}
You can't really do this with one liner. Of course you could use a method reference, but then your returned Stream
would be of a different type (assuming foo
returns a type):
myStream.map(Obj::foo) // this will turn into Stream<T>, where T is
// the return type of foo, instead of Stream<Obj>
Besides that your map
operation is stateful
, which is strongly discouraged. Your code will compile and might even work as you want it to - but it might later fail. map
operations should be stateless
.
You can use map
method but you have to create helper method which returns this
. For example:
public class Fluent {
public static <T> Function<T, T> of(Consumer<T> consumer) {
return t -> {
consumer.accept(t);
return t;
};
}
}
And use it when you want to call void
method:
list.stream().map(Fluent.of(SomeClass::method));
or if you want to use it with method with some argument:
list.stream().map(Fluent.of(x -> x.method("hello")))
I think you are looking for Stream.peek
. But read the docs carefully, as it was designed mainly as a debug method. From the docs:
This method exists mainly to support debugging, where you want to see the elements as they flow past a certain point in a pipeline
The action passed to peek
must be non interfering.
I think the cleanest way is to add a mutator to the objects in the stream.
For example,
class Victim {
private String tag;
private Victim withTag(String t)
this.tag = t;
return this;
}
}
List<Victim> base = List.of(new Victim());
Stream<Victim> transformed = base.stream().map(v -> v.withTag("myTag"));
If you prefer (and many will), you can have the withTag method create and return a new Victim; this allows you to make Victim immutable.
without breaking the stream chain
? may be an example?apply
method here:things.stream().apply(o -> o.status = newStatus).map(....)....
Same idea asforEach
, but does not "break the chain", e.g., returns aStream<T>
instead ofvoid
.