This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko.git
The following commit(s) were added to refs/heads/main by this push:
new 580f12c29f clean GraphAssembly in scaladoc since which has gone for a
while (#579)
580f12c29f is described below
commit 580f12c29fb61b65758af9b0c31494af0af17175
Author: Dongxu Wang <[email protected]>
AuthorDate: Fri Aug 18 07:07:52 2023 +0800
clean GraphAssembly in scaladoc since which has gone for a while (#579)
---
.../main/scala/org/apache/pekko/stream/impl/TraversalBuilder.scala | 3 +--
.../scala/org/apache/pekko/stream/impl/fusing/GraphInterpreter.scala | 5 +++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git
a/stream/src/main/scala/org/apache/pekko/stream/impl/TraversalBuilder.scala
b/stream/src/main/scala/org/apache/pekko/stream/impl/TraversalBuilder.scala
index c13c6d4b55..8e2c6fc3d3 100644
--- a/stream/src/main/scala/org/apache/pekko/stream/impl/TraversalBuilder.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/impl/TraversalBuilder.scala
@@ -38,8 +38,7 @@ import pekko.util.unused
* number (and those which are not receive different numbers). This feature
can be used to
* - materialize a graph, using the slots as indices to an array of
Publishers/Subscribers that need to be wired
* together
- * - fuse a graph, using the slots to construct a
[[pekko.stream.impl.fusing.GraphInterpreter.GraphAssembly]] which
- * uses a similar layout
+ * - fuse a graph
* - create a DOT formatted output for visualization
* - convert the graph to another data structure
*
diff --git
a/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/GraphInterpreter.scala
b/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/GraphInterpreter.scala
index 1d5df9dc82..b3be4fbe5b 100644
---
a/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/GraphInterpreter.scala
+++
b/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/GraphInterpreter.scala
@@ -140,8 +140,9 @@ import pekko.stream.stage._
/**
* INTERNAL API
*
- * From an external viewpoint, the GraphInterpreter takes an assembly of graph
processing stages encoded as a
- * [[GraphInterpreter#GraphAssembly]] object and provides facilities to
execute and interact with this assembly.
+ * From an external viewpoint, the GraphInterpreter takes an assembly of graph
processing stages and provides facilities
+ * to execute and interact with this assembly.
+ *
* The lifecycle of the Interpreter is roughly the following:
* - [[init]] is called
* - [[execute]] is called whenever there is need for execution, providing an
upper limit on the processed events
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
