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

diffs when running scalafmtAll (#155)

Browse source
This commit is contained in:
PJ Fanning 2023-02-09 14:38:45 +01:00 • committed by GitHub
parent 5d4437e94c
commit 8338bfed8b
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
4 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

2
actor/src/main/scala/org/apache/pekko/event/japi/EventBusJavaAPI.scala
View file

@ -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] { abstract class ManagedActorEventBus[E](system: ActorSystem) extends EventBus[E, ActorRef, ActorRef] {
private val bus = new pekko.event.ActorEventBus with pekko.event.ManagedActorClassification private val bus = new pekko.event.ActorEventBus with pekko.event.ManagedActorClassification
with pekko.event.ActorClassifier { with pekko.event.ActorClassifier {
type Event = E type Event = E
override val system = ManagedActorEventBus.this.system override val system = ManagedActorEventBus.this.system

2
docs/src/test/scala/docs/actor/SharedMutableStateDocSpec.scala
View file

@ -61,7 +61,7 @@ class SharedMutableStateDocSpec {
// Very bad: shared mutable state will cause your // Very bad: shared mutable state will cause your
// application to break in weird ways // application to break in weird ways
Future { state = "This will race" } 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 state = received.msg
} }

2
remote/src/test/scala/org/apache/pekko/remote/artery/RollingEventLogSimulationSpec.scala
View file

@ -110,7 +110,7 @@ class RollingEventLogSimulationSpec extends PekkoSpec {
val instructions: Array[Instruction] = val instructions: Array[Instruction] =
(Array(AdvanceHeader, TryMarkDirty) :+ (Array(AdvanceHeader, TryMarkDirty) :+
WriteId) ++ WriteId) ++
Array.fill(EntrySize - 2)(WriteByte) :+ Array.fill(EntrySize - 2)(WriteByte) :+
Commit Commit

2
stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/GraphUnzipWithSpec.scala
View file

@ -288,7 +288,7 @@ class GraphUnzipWithSpec extends StreamSpec("""
RunnableGraph RunnableGraph
.fromGraph(GraphDSL.create() { implicit b => .fromGraph(GraphDSL.create() { implicit b =>
val split22 = (a: (List[Int])) => val split22 = (a: List[Int]) =>
( (
a(0), a(0),
a(0).toString, a(0).toString,