Add asJava/asScala to RunnableGraph #26245

This commit is contained in:
Martynas Mickevičius 2019-02-07 16:41:49 +02:00 committed by Johan Andrén
parent 98a5f24835
commit d6ae3f1da9
16 changed files with 97 additions and 12 deletions

View file

@ -27,7 +27,7 @@ public class SinkAsJavaSourceTest extends StreamTest {
@ClassRule
public static AkkaJUnitActorSystemResource actorSystemResource =
new AkkaJUnitActorSystemResource("OutputStreamSource", Utils.UnboundedMailboxConfig());
new AkkaJUnitActorSystemResource("SinkAsJavaSourceTest", Utils.UnboundedMailboxConfig());
@Test
public void mustBeAbleToUseAsJavaStream() throws Exception {