From a70a193f5a64b39aa09d9595f9d41d95032e8a55 Mon Sep 17 00:00:00 2001 From: Arnout Engelen Date: Fri, 5 Apr 2019 17:21:29 +0200 Subject: [PATCH] Fix akka-stream javadoc errors --- .../src/main/scala/akka/stream/stage/GraphStage.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/akka-stream/src/main/scala/akka/stream/stage/GraphStage.scala b/akka-stream/src/main/scala/akka/stream/stage/GraphStage.scala index bed08d5db0..31e5806be6 100644 --- a/akka-stream/src/main/scala/akka/stream/stage/GraphStage.scala +++ b/akka-stream/src/main/scala/akka/stream/stage/GraphStage.scala @@ -931,7 +931,7 @@ abstract class GraphStageLogic private[stream] (val inCount: Int, val outCount: andThen() if (followUps != null) { - /** + /* * If (while executing andThen() callback) handler was changed to new emitting, * we should add it to the end of emission queue */ @@ -942,7 +942,7 @@ abstract class GraphStageLogic private[stream] (val inCount: Int, val outCount: val next = dequeue() if (next.isInstanceOf[EmittingCompletion[_]]) { - /** + /* * If next element is emitting completion and there are some elements after it, * we to need pass them before completion */ @@ -1125,7 +1125,7 @@ abstract class GraphStageLogic private[stream] (val inCount: Int, val outCount: override def invokeWithFeedback(event: T): Future[Done] = { val promise: Promise[Done] = Promise[Done]() - /** + /* * Add this promise to the owning logic, so it can be completed afterPostStop if it was never handled otherwise. * Returns whether the logic is still running. */