raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

Fix akka-stream javadoc errors

Browse source
This commit is contained in:
Arnout Engelen 2019-04-05 17:21:29 +02:00
parent f798481de5
commit a70a193f5a
No known key found for this signature in database
GPG key ID: BB8C0F854A1E2105
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-stream/src/main/scala/akka/stream/stage/GraphStage.scala
View file

@ -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.
*/