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/pekko.git
The following commit(s) were added to refs/heads/main by this push:
new 6fdd2dffcb try to fix doc build issue (#2279)
6fdd2dffcb is described below
commit 6fdd2dffcbb52fb3e895bb07516a6d94ae09dd10
Author: PJ Fanning <[email protected]>
AuthorDate: Mon Sep 29 11:04:08 2025 +0100
try to fix doc build issue (#2279)
---
.../main/scala/org/apache/pekko/stream/impl/fusing/SourceSink.scala | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/SourceSink.scala
b/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/SourceSink.scala
index db58cc93e6..2a447293fa 100644
--- a/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/SourceSink.scala
+++ b/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/SourceSink.scala
@@ -47,11 +47,11 @@ import pekko.stream.stage.{
override def createLogicAndMaterializedValue(
inheritedAttributes: Attributes): (GraphStageLogic, Source[Any,
NotUsed]) = {
- /**
+ /*
* NOTE: in the current implementation of Pekko Stream,
- * We have to materialization twice to do the piping, which means, even we
can treat the Sink as a Source.
+ * We have to materialize twice to do the piping, which means that we can
treat the Sink as a Source.
*
- * In an idea word this stage should be purged out by the materializer
optimization,
+ * In an ideal world, this stage should be purged out by the materializer
optimization,
* and we can directly connect the upstream to the downstream.
*/
object logic extends TimerGraphStageLogic(shape) with InHandler with
OutHandler { self =>
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
