Skip to content

Commit f4b1814

Browse files
committed
Scalafix and formatting fixes
1 parent 72b1a98 commit f4b1814

File tree

11 files changed

+31
-32
lines changed

11 files changed

+31
-32
lines changed

actors-akka/src/main/scala/reactivemongo/actors/actor/package.scala

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,5 +12,4 @@ package object actor {
1212
val Props = akka.actor.Props
1313
type Terminated = akka.actor.Terminated
1414
type Cancellable = akka.actor.Cancellable
15-
1615
}
Lines changed: 4 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,9 @@
11
package reactivemongo.actors
22

3-
import akka.util.{
4-
ByteString => PekkoByteString,
5-
Timeout => PekkoTimeout
6-
}
7-
83
package object util {
9-
type Timeout = PekkoTimeout
10-
val Timeout = PekkoTimeout
11-
12-
type ByteString = PekkoByteString
13-
val ByteString = PekkoByteString
4+
type Timeout = akka.util.Timeout
5+
val Timeout = akka.util.Timeout
146

7+
type ByteString = akka.util.ByteString
8+
val ByteString = akka.util.ByteString
159
}

actors-pekko/src/main/scala/reactivemongo/actors/actor/package.scala

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,5 +12,4 @@ package object actor {
1212
val Props = org.apache.pekko.actor.Props
1313
type Terminated = org.apache.pekko.actor.Terminated
1414
type Cancellable = org.apache.pekko.actor.Cancellable
15-
1615
}
Lines changed: 4 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -1,15 +1,9 @@
11
package reactivemongo.actors
22

3-
import org.apache.pekko.util.{
4-
ByteString => PekkoByteString,
5-
Timeout => PekkoTimeout
6-
}
7-
83
package object util {
9-
type Timeout = PekkoTimeout
10-
val Timeout = PekkoTimeout
11-
12-
type ByteString = PekkoByteString
13-
val ByteString = PekkoByteString
4+
type Timeout = org.apache.pekko.util.Timeout
5+
val Timeout = org.apache.pekko.util.Timeout
146

7+
type ByteString = org.apache.pekko.util.ByteString
8+
val ByteString = org.apache.pekko.util.ByteString
159
}

build.sbt

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ lazy val `ReactiveMongo-Test` = project
7575
.settings(
7676
description := "ReactiveMongo test helpers"
7777
)
78-
.dependsOn(`ReactiveMongo`).dependsOn()
78+
.dependsOn(`ReactiveMongo`)
7979

8080
// ---
8181

driver/src/main/scala/api/AsyncDriver.scala

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -18,11 +18,17 @@ import reactivemongo.core.actors.{
1818
StandardDBSystemWithX509
1919
}
2020
import reactivemongo.core.nodeset.Authenticate
21-
import reactivemongo.actors.actor.{ Actor, ActorRef, ActorSystem }
21+
22+
import com.typesafe.config.Config
23+
import reactivemongo.actors.actor.{
24+
Actor,
25+
ActorRef,
26+
ActorSystem,
27+
Props,
28+
Terminated
29+
}
2230
import reactivemongo.actors.pattern.ask._
2331
import reactivemongo.actors.util.Timeout
24-
import com.typesafe.config.Config
25-
import reactivemongo.actors.actor.{ Props, Terminated }
2632

2733
/**
2834
* The asynchronous driver (see [[MongoConnection]]).
@@ -38,6 +44,7 @@ import reactivemongo.actors.actor.{ Props, Terminated }
3844
*
3945
* @param config a custom configuration (otherwise the default options are used)
4046
* @param classLoader a classloader used to load the actor system
47+
*
4148
* @define parsedURIParam the URI parsed by [[reactivemongo.api.MongoConnection.fromString]]
4249
* @define connectionNameParam the name for the connection pool
4350
* @define optionsParam the options for the new connection pool

driver/src/main/scala/api/Failover.scala

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,12 @@
11
package reactivemongo.api
22

3-
import reactivemongo.actors.pattern.after
4-
53
import scala.util.{ Failure, Success, Try }
64
import scala.util.control.NonFatal
5+
76
import scala.concurrent.{ ExecutionContext, Future }
87
import scala.concurrent.duration.{ Duration, FiniteDuration }
8+
9+
import reactivemongo.actors.pattern.after
910
import reactivemongo.util.LazyLogger
1011

1112
private[reactivemongo] final class Failover[A](

driver/src/main/scala/core/actors/MongoDBSystem.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -85,9 +85,9 @@ import reactivemongo.api.commands.{
8585
UpsertedFactory
8686
}
8787

88-
import reactivemongo.actors.actor.{ Actor, ActorRef, Cancellable }
8988
import com.github.ghik.silencer.silent
9089
import external.reactivemongo.ConnectionListener
90+
import reactivemongo.actors.actor.{ Actor, ActorRef, Cancellable }
9191
import reactivemongo.util.{ LazyLogger, SimpleRing }
9292

9393
/** Main actor that processes the requests. */

driver/src/test/scala/ApiTesting.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,6 @@ import scala.concurrent.duration.{ FiniteDuration, SECONDS }
1010
import reactivemongo.io.netty.buffer.{ ByteBuf, Unpooled }
1111
import reactivemongo.io.netty.channel.{ Channel, ChannelId, DefaultChannelId }
1212

13-
import reactivemongo.actors.pattern.ask._
1413
import reactivemongo.core.actors
1514
import reactivemongo.core.errors.DatabaseException
1615
import reactivemongo.core.netty.ChannelFactory
@@ -33,6 +32,7 @@ import reactivemongo.api.collections.QueryCodecs
3332
import reactivemongo.api.commands.CommandKind
3433

3534
import reactivemongo.actors.actor.ActorRef
35+
import reactivemongo.actors.pattern.ask._
3636
import reactivemongo.actors.util.Timeout
3737

3838
import actors.{

driver/src/test/scala/NodeSetSpec.scala

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
11
package reactivemongo
22

3-
import reactivemongo.actors.pattern.ask._
4-
53
import scala.collection.immutable.ListSet
4+
65
import scala.concurrent.{ Await, Future }
6+
77
import reactivemongo.core.actors.{
88
PrimaryAvailable,
99
PrimaryUnavailable,
@@ -21,15 +21,19 @@ import reactivemongo.core.nodeset.{
2121
PingInfo
2222
}
2323
import reactivemongo.core.protocol.ProtocolMetadata
24+
2425
import reactivemongo.api.{
2526
AsyncDriver,
2627
MongoConnection,
2728
MongoConnectionOptions,
2829
ReadPreference
2930
}
31+
3032
import org.specs2.concurrent.ExecutionEnv
3133
import org.specs2.matcher.MatchResult
34+
3235
import reactivemongo.actors.actor.ActorRef
36+
import reactivemongo.actors.pattern.ask._
3337
import reactivemongo.actors.testkit.TestActorRef
3438

3539
final class NodeSetSpec(

0 commit comments

Comments
 (0)