raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

tests compile apart from flexi things

Browse source
This commit is contained in:
Roland Kuhn 2015-02-27 11:45:46 +01:00
parent 703fb7891b
commit 6416dc2f25
2 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-stream-tests/src/test/java/akka/stream/javadsl/SourceTest.java
View file

@ -260,7 +260,7 @@ public class SourceTest extends StreamTest {
return input1.iterator();
}
};
Source.from(input).runForeach(new Procedure<Integer>() {
Source.fromIterator(input).runForeach(new Procedure<Integer>() {
public void apply(Integer elem) {
probe.getRef().tell(elem, ActorRef.noSender());
}