From 1756541dcb64c6f8314653f02b88b71d544ebb3a Mon Sep 17 00:00:00 2001
From: gosubpl <github@gosub.pl>
Date: Fri, 8 Jul 2016 11:15:52 +0200
Subject: [PATCH] =doc #20885 small fix and clarification for Java
 stream-graphs example (#20894)

* #20885 small fix and clarification for Java stream-graphs example

* #20885 GraphDSLDocTest comment wording improved
---
 .../rst/java/code/docs/stream/GraphDSLDocTest.java  | 13 ++++++-------
 1 file changed, 6 insertions(+), 7 deletions(-)

diff --git a/akka-docs/rst/java/code/docs/stream/GraphDSLDocTest.java b/akka-docs/rst/java/code/docs/stream/GraphDSLDocTest.java
index ddb5149f14..51fe15ef40 100644
--- a/akka-docs/rst/java/code/docs/stream/GraphDSLDocTest.java
+++ b/akka-docs/rst/java/code/docs/stream/GraphDSLDocTest.java
@@ -50,25 +50,24 @@ public class GraphDSLDocTest extends AbstractJavaTest {
     //#simple-graph-dsl
     final Source<Integer, NotUsed> in = Source.from(Arrays.asList(1, 2, 3, 4, 5));
     final Sink<List<String>, CompletionStage<List<String>>> sink = Sink.head();
-    final Sink<List<Integer>, CompletionStage<List<Integer>>> sink2 = Sink.head();
     final Flow<Integer, Integer, NotUsed> f1 = Flow.of(Integer.class).map(elem -> elem + 10);
     final Flow<Integer, Integer, NotUsed> f2 = Flow.of(Integer.class).map(elem -> elem + 20);
     final Flow<Integer, String, NotUsed> f3 = Flow.of(Integer.class).map(elem -> elem.toString());
     final Flow<Integer, Integer, NotUsed> f4 = Flow.of(Integer.class).map(elem -> elem + 30);
 
     final RunnableGraph<CompletionStage<List<String>>> result =
-      RunnableGraph.<CompletionStage<List<String>>>fromGraph(
-        GraphDSL
-          .create(
-            sink,
-            (builder, out) -> {
+      RunnableGraph.fromGraph(
+        GraphDSL     // create() function binds sink, out which is sink's out port and builder DSL
+          .create(   // we need to reference out's shape in the builder DSL below (in to() function)
+            sink,                // previously created sink (Sink)
+            (builder, out) -> {  // variables: builder (GraphDSL.Builder) and out (SinkShape)
               final UniformFanOutShape<Integer, Integer> bcast = builder.add(Broadcast.create(2));
               final UniformFanInShape<Integer, Integer> merge = builder.add(Merge.create(2));
 
               final Outlet<Integer> source = builder.add(in).out();
               builder.from(source).via(builder.add(f1))
                 .viaFanOut(bcast).via(builder.add(f2)).viaFanIn(merge)
-                .via(builder.add(f3.grouped(1000))).to(out);
+                .via(builder.add(f3.grouped(1000))).to(out);  // to() expects a SinkShape
               builder.from(bcast).via(builder.add(f4)).toFanIn(merge);
               return ClosedShape.getInstance();
             }));