diff --git a/akka-docs/rst/java/testing.rst b/akka-docs/rst/java/testing.rst index 20417ab6dd..e42e58093d 100644 --- a/akka-docs/rst/java/testing.rst +++ b/akka-docs/rst/java/testing.rst @@ -497,7 +497,7 @@ Create the child using JavaTestKit ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ The ``JavaTestKit`` class can in fact create actors that will run with the test probe as parent. -This will cause any messages the the child actor sends to `context().getParent()` to +This will cause any messages the child actor sends to `context().getParent()` to end up in the test probe. .. includecode:: code/docs/testkit/ParentChildTest.java#test-TestProbe-parent diff --git a/akka-docs/rst/scala/testing.rst b/akka-docs/rst/scala/testing.rst index bae0ae8292..3c9964ba42 100644 --- a/akka-docs/rst/scala/testing.rst +++ b/akka-docs/rst/scala/testing.rst @@ -576,7 +576,7 @@ Create the child using TestProbe ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ The ``TestProbe`` class can in fact create actors that will run with the test probe as parent. -This will cause any messages the the child actor sends to `context.parent` to +This will cause any messages the child actor sends to `context.parent` to end up in the test probe. .. includecode:: code/docs/testkit/ParentChildSpec.scala#test-TestProbe-parent diff --git a/akka-remote/src/main/java/akka/remote/artery/AeronErrorLog.java b/akka-remote/src/main/java/akka/remote/artery/AeronErrorLog.java index 87f0389594..a31170a49e 100644 --- a/akka-remote/src/main/java/akka/remote/artery/AeronErrorLog.java +++ b/akka-remote/src/main/java/akka/remote/artery/AeronErrorLog.java @@ -31,7 +31,7 @@ import java.util.concurrent.atomic.AtomicLong; /** * Application to print out errors recorded in the command-and-control (cnc) file is maintained by media driver in shared - * memory. This application reads the the cnc file and prints the distinct errors. Layout of the cnc file is described in + * memory. This application reads the cnc file and prints the distinct errors. Layout of the cnc file is described in * {@link CncFileDescriptor}. */ public class AeronErrorLog diff --git a/akka-remote/src/test/java/akka/remote/artery/AeronStat.java b/akka-remote/src/test/java/akka/remote/artery/AeronStat.java index 3b63943f12..56240aeae7 100644 --- a/akka-remote/src/test/java/akka/remote/artery/AeronStat.java +++ b/akka-remote/src/test/java/akka/remote/artery/AeronStat.java @@ -38,7 +38,7 @@ import static io.aeron.driver.status.SystemCounterDescriptor.SYSTEM_COUNTER_TYPE /** * Tool for printing out Aeron counters. A command-and-control (cnc) file is maintained by media driver - * in shared memory. This application reads the the cnc file and prints the counters. Layout of the cnc file is + * in shared memory. This application reads the cnc file and prints the counters. Layout of the cnc file is * described in {@link CncFileDescriptor}. * * This tool accepts filters on the command line, e.g. for connections only see example below: diff --git a/akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala b/akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala index eb0ca6f07e..d07a47cdc9 100644 --- a/akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala +++ b/akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala @@ -1869,7 +1869,7 @@ final class Flow[-In, +Out, +Mat](delegate: scaladsl.Flow[In, Out, Mat]) extends new Flow(delegate.watchTermination()((left, right) ⇒ matF(left, right.toJava))) /** - * Materializes to `FlowMonitor[Out]` that allows monitoring of the the current flow. All events are propagated + * Materializes to `FlowMonitor[Out]` that allows monitoring of the current flow. All events are propagated * by the monitor unchanged. Note that the monitor inserts a memory barrier every time it processes an * event, and may therefor affect performance. * The `combine` function is used to combine the `FlowMonitor` with this flow's materialized value. 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 acd9f675b8..b7b1b24a5b 100644 --- a/akka-stream/src/main/scala/akka/stream/javadsl/Source.scala +++ b/akka-stream/src/main/scala/akka/stream/javadsl/Source.scala @@ -2068,7 +2068,7 @@ final class Source[+Out, +Mat](delegate: scaladsl.Source[Out, Mat]) extends Grap new Source(delegate.watchTermination()((left, right) ⇒ matF(left, right.toJava))) /** - * Materializes to `FlowMonitor[Out]` that allows monitoring of the the current flow. All events are propagated + * Materializes to `FlowMonitor[Out]` that allows monitoring of the current flow. All events are propagated * by the monitor unchanged. Note that the monitor inserts a memory barrier every time it processes an * event, and may therefor affect performance. * The `combine` function is used to combine the `FlowMonitor` with this flow's materialized value. diff --git a/akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala b/akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala index af82e0077b..272fdf1b5c 100644 --- a/akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala +++ b/akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala @@ -2192,7 +2192,7 @@ trait FlowOpsMat[+Out, +Mat] extends FlowOps[Out, Mat] { def mapMaterializedValue[Mat2](f: Mat ⇒ Mat2): ReprMat[Out, Mat2] /** - * Materializes to `FlowMonitor[Out]` that allows monitoring of the the current flow. All events are propagated + * Materializes to `FlowMonitor[Out]` that allows monitoring of the current flow. All events are propagated * by the monitor unchanged. Note that the monitor inserts a memory barrier every time it processes an * event, and may therefor affect performance. * The `combine` function is used to combine the `FlowMonitor` with this flow's materialized value.