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

+str #18275 Java DSL: Flow.of(MyClass.class).via(otherFlow) throws ClassCastException

Browse source
This commit is contained in:
Alexander Golubev 2015-08-24 00:22:24 -04:00
parent a5496bfd57
commit e0a430dc14
3 changed files with 70 additions and 18 deletions
Download patch file Download diff file Expand all files Collapse all files

33
akka-stream-tests/src/test/java/akka/stream/javadsl/FlowTest.java
View file

@ -556,4 +556,37 @@ public class FlowTest extends StreamTest {
Await.ready(future, Duration.apply(200, TimeUnit.MILLISECONDS));
}
@Test
public void mustBeAbleToMaterializeIdentityWithJavaFlow() throws Exception {
final JavaTestKit probe = new JavaTestKit(system);
final List<String> input = Arrays.asList("A", "B", "C");
Flow<String,String,?> otherFlow = Flow.of(String.class);
Flow<String,String,?> myFlow = Flow.of(String.class).via(otherFlow);
Source.from(input).via(myFlow).runWith(Sink.foreach(new Procedure<String>() { // Scala Future
public void apply(String elem) {
probe.getRef().tell(elem, ActorRef.noSender());
}
}), materializer);
probe.expectMsgAllOf("A","B","C");
}
@Test
public void mustBeAbleToMaterializeIdentityToJavaSink() throws Exception {
final JavaTestKit probe = new JavaTestKit(system);
final List<String> input = Arrays.asList("A", "B", "C");
Flow<String,String,?> otherFlow = Flow.of(String.class);
Sink<String,BoxedUnit> sink = Flow.of(String.class).to(otherFlow.to(Sink.foreach(new Procedure<String>() { // Scala Future
public void apply(String elem) {
probe.getRef().tell(elem, ActorRef.noSender());
}
})));
Source.from(input).to(sink).run(materializer);
probe.expectMsgAllOf("A","B","C");
}
}