diff --git a/akka-stream/src/main/scala/akka/stream/impl/ActorRefSource.scala b/akka-stream/src/main/scala/akka/stream/impl/ActorRefSource.scala index b0330e09c6..c713d9f92a 100644 --- a/akka-stream/src/main/scala/akka/stream/impl/ActorRefSource.scala +++ b/akka-stream/src/main/scala/akka/stream/impl/ActorRefSource.scala @@ -53,7 +53,8 @@ private object ActorRefSource { override val ref: ActorRef = getEagerStageActor(eagerMaterializer, poisonPillCompatibility = true) { case (_, PoisonPill) => - log.warning("for backwards compatibility: PoisonPill will not be supported in the future") + log.warning( + "PoisonPill only completes ActorRefSource for backwards compatibility and not be supported in the future. Send Status.Success(CompletionStrategy) instead") completeStage() case (_, m) if failureMatcher.isDefinedAt(m) => failStage(failureMatcher(m)) diff --git a/akka-stream/src/main/scala/akka/stream/javadsl/Source.scala b/akka-stream/src/main/scala/akka/stream/javadsl/Source.scala index 79b614e61b..96a3e460d1 100755 --- a/akka-stream/src/main/scala/akka/stream/javadsl/Source.scala +++ b/akka-stream/src/main/scala/akka/stream/javadsl/Source.scala @@ -319,9 +319,9 @@ object Source { * completion. * * The stream can be completed successfully by sending the actor reference a [[akka.actor.Status.Success]]. - * If the content is [[akka.stream.CompletionStrategy.immediately]] the completion will be signaled immidiately, + * If the content is [[akka.stream.CompletionStrategy.immediately]] the completion will be signaled immediately, * otherwise if the content is [[akka.stream.CompletionStrategy.draining]] (or anything else) - * already buffered elements will be signaled before siganling completion. + * already buffered elements will be signaled before signaling completion. * Sending [[akka.actor.PoisonPill]] will signal completion immediately but this behavior is deprecated and scheduled to be removed. * * The stream can be completed with failure by sending a [[akka.actor.Status.Failure]] to the diff --git a/akka-stream/src/main/scala/akka/stream/scaladsl/Source.scala b/akka-stream/src/main/scala/akka/stream/scaladsl/Source.scala index bb27cc0ba0..6853b3c79a 100644 --- a/akka-stream/src/main/scala/akka/stream/scaladsl/Source.scala +++ b/akka-stream/src/main/scala/akka/stream/scaladsl/Source.scala @@ -543,9 +543,9 @@ object Source { * this Source; as such, it is never safe to assume the downstream will always generate demand. * * The stream can be completed successfully by sending the actor reference a [[akka.actor.Status.Success]]. - * If the content is [[akka.stream.CompletionStrategy.immediately]] the completion will be signaled immidiately, + * If the content is [[akka.stream.CompletionStrategy.immediately]] the completion will be signaled immediately, * otherwise if the content is [[akka.stream.CompletionStrategy.draining]] (or anything else) - * already buffered elements will be signaled before siganling completion. + * already buffered elements will be signaled before signaling completion. * Sending [[akka.actor.PoisonPill]] will signal completion immediately but this behavior is deprecated and scheduled to be removed. * * The stream can be completed with failure by sending a [[akka.actor.Status.Failure]] to the