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

Merge pull request #26693 from akka/fixDocs

Browse source 
Fix akka-stream javadoc errors
This commit is contained in:
Patrik Nordwall 2019-04-15 09:20:36 +02:00 • committed by GitHub
commit 8c2edd1bf0
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
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.
*/