diff --git a/actor-typed/src/main/scala/org/apache/pekko/actor/typed/scaladsl/AskPattern.scala b/actor-typed/src/main/scala/org/apache/pekko/actor/typed/scaladsl/AskPattern.scala index 7a4560be958..66892700cb6 100644 --- a/actor-typed/src/main/scala/org/apache/pekko/actor/typed/scaladsl/AskPattern.scala +++ b/actor-typed/src/main/scala/org/apache/pekko/actor/typed/scaladsl/AskPattern.scala @@ -76,7 +76,7 @@ object AskPattern { * val f: Future[Reply] = target ? (replyTo => Request("hello", replyTo)) * }}} * - * Note: it is preferrable to use the non-symbolic ask method as it easier allows for wildcards for + * Note: it is preferable to use the non-symbolic ask method as it easier allows for wildcards for * the `replyTo: ActorRef`. * * @tparam Res The response protocol, what the other actor sends back @@ -115,7 +115,7 @@ object AskPattern { */ @nowarn("msg=never used") def ask[Res](replyTo: ActorRef[Res] => Req)(implicit timeout: Timeout, scheduler: Scheduler): Future[Res] = { - // We do not currently use the implicit sched, but want to require it + // We do not currently use the implicit scheduler, but want to require it // because it might be needed when we move to a 'native' typed runtime, see #24219 ref match { case a: InternalRecipientRef[Req] => askClassic[Req, Res](a, timeout, replyTo) diff --git a/actor-typed/src/main/scala/org/apache/pekko/actor/typed/scaladsl/Routers.scala b/actor-typed/src/main/scala/org/apache/pekko/actor/typed/scaladsl/Routers.scala index ef815041518..ddc2d8ade1c 100644 --- a/actor-typed/src/main/scala/org/apache/pekko/actor/typed/scaladsl/Routers.scala +++ b/actor-typed/src/main/scala/org/apache/pekko/actor/typed/scaladsl/Routers.scala @@ -185,5 +185,5 @@ trait PoolRouter[T] extends Behavior[T] { /** * Any message that the predicate returns true for will be broadcast to all routees. */ - def withBroadcastPredicate(pred: T => Boolean): PoolRouter[T] + def withBroadcastPredicate(predicate: T => Boolean): PoolRouter[T] } diff --git a/stream-typed/src/main/scala/org/apache/pekko/stream/typed/javadsl/ActorFlow.scala b/stream-typed/src/main/scala/org/apache/pekko/stream/typed/javadsl/ActorFlow.scala index 1edd43f846f..e683830b0bd 100644 --- a/stream-typed/src/main/scala/org/apache/pekko/stream/typed/javadsl/ActorFlow.scala +++ b/stream-typed/src/main/scala/org/apache/pekko/stream/typed/javadsl/ActorFlow.scala @@ -49,7 +49,7 @@ object ActorFlow { * The operator fails with an [[pekko.stream.WatchedActorTerminatedException]] if the target actor is terminated, * or with an [[java.util.concurrent.TimeoutException]] in case the ask exceeds the timeout passed in. * - * Adheres to the [[ActorAttributes.SupervisionStrategy]] attribute. + * Adheres to the [[pekko.stream.ActorAttributes.SupervisionStrategy]] attribute. * * '''Emits when''' the futures (in submission order) created by the ask pattern internally are completed * @@ -105,7 +105,7 @@ object ActorFlow { * The operator fails with an [[pekko.stream.WatchedActorTerminatedException]] if the target actor is terminated, * or with an [[java.util.concurrent.TimeoutException]] in case the ask exceeds the timeout passed in. * - * Adheres to the [[ActorAttributes.SupervisionStrategy]] attribute. + * Adheres to the [[pekko.stream.ActorAttributes.SupervisionStrategy]] attribute. * * '''Emits when''' the futures (in submission order) created by the ask pattern internally are completed * diff --git a/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubSource.scala b/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubSource.scala index 6104422b66b..924cbb87de9 100755 --- a/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubSource.scala +++ b/stream/src/main/scala/org/apache/pekko/stream/javadsl/SubSource.scala @@ -250,7 +250,7 @@ class SubSource[Out, Mat]( * as they are illegal as stream elements - according to the Reactive Streams specification. * * This operator doesn't handle upstream's completion signal since the state kept in the closure can be lost. - * Use [[FlowOps.statefulMap]] instead. + * Use [[pekko.stream.scaladsl.FlowOps.statefulMap]] instead. * * Adheres to the [[ActorAttributes.SupervisionStrategy]] attribute. *