diff --git a/actor/src/main/scala/org/apache/pekko/event/japi/EventBusJavaAPI.scala b/actor/src/main/scala/org/apache/pekko/event/japi/EventBusJavaAPI.scala index 2fe7c5e55d..0a790b2503 100644 --- a/actor/src/main/scala/org/apache/pekko/event/japi/EventBusJavaAPI.scala +++ b/actor/src/main/scala/org/apache/pekko/event/japi/EventBusJavaAPI.scala @@ -202,7 +202,7 @@ abstract class ScanningEventBus[E, S, C] extends EventBus[E, S, C] { */ abstract class ManagedActorEventBus[E](system: ActorSystem) extends EventBus[E, ActorRef, ActorRef] { private val bus = new pekko.event.ActorEventBus with pekko.event.ManagedActorClassification - with pekko.event.ActorClassifier { + with pekko.event.ActorClassifier { type Event = E override val system = ManagedActorEventBus.this.system diff --git a/docs/src/test/scala/docs/actor/SharedMutableStateDocSpec.scala b/docs/src/test/scala/docs/actor/SharedMutableStateDocSpec.scala index f5d5554140..a2278e5f6c 100644 --- a/docs/src/test/scala/docs/actor/SharedMutableStateDocSpec.scala +++ b/docs/src/test/scala/docs/actor/SharedMutableStateDocSpec.scala @@ -61,7 +61,7 @@ class SharedMutableStateDocSpec { // Very bad: shared mutable state will cause your // application to break in weird ways Future { state = "This will race" } - ((echoActor ? Message("With this other one")).mapTo[Message]).foreach { received => + (echoActor ? Message("With this other one")).mapTo[Message].foreach { received => state = received.msg } diff --git a/remote/src/test/scala/org/apache/pekko/remote/artery/RollingEventLogSimulationSpec.scala b/remote/src/test/scala/org/apache/pekko/remote/artery/RollingEventLogSimulationSpec.scala index bcab4e11a6..f9e31ab185 100644 --- a/remote/src/test/scala/org/apache/pekko/remote/artery/RollingEventLogSimulationSpec.scala +++ b/remote/src/test/scala/org/apache/pekko/remote/artery/RollingEventLogSimulationSpec.scala @@ -110,7 +110,7 @@ class RollingEventLogSimulationSpec extends PekkoSpec { val instructions: Array[Instruction] = (Array(AdvanceHeader, TryMarkDirty) :+ - WriteId) ++ + WriteId) ++ Array.fill(EntrySize - 2)(WriteByte) :+ Commit diff --git a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphUnzipWithSpec.scala b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphUnzipWithSpec.scala index a4fb561262..163ea4b597 100644 --- a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphUnzipWithSpec.scala +++ b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphUnzipWithSpec.scala @@ -288,7 +288,7 @@ class GraphUnzipWithSpec extends StreamSpec(""" RunnableGraph .fromGraph(GraphDSL.create() { implicit b => - val split22 = (a: (List[Int])) => + val split22 = (a: List[Int]) => ( a(0), a(0).toString,