Reimport

bitlap · Dec 28, 2023 · 3240851 · 3240851
1 parent e7c8831
commit 3240851
Show file tree

Hide file tree

Showing 7 changed files with 14 additions and 15 deletions.
diff --git a/zio-pekko-cluster/src/main/scala/zio/pekko/cluster/Cluster.scala b/zio-pekko-cluster/src/main/scala/zio/pekko/cluster/Cluster.scala
@@ -1,8 +1,8 @@
 package zio.pekko.cluster
 
-import zio.{ Exit, Queue, Runtime, Unsafe, ZIO }
+import zio._
 
-import org.apache.pekko.actor.{ Actor, ActorSystem, Address, PoisonPill, Props }
+import org.apache.pekko.actor._
 import org.apache.pekko.cluster.{ Cluster => PekkoCluster }
 import org.apache.pekko.cluster.ClusterEvent._
 
@@ -72,7 +72,7 @@ object Cluster {
     initialStateAsEvents: Boolean
   ) extends Actor {
 
-    val initialState: SubscriptionInitialStateMode =
+    private val initialState: SubscriptionInitialStateMode =
       if (initialStateAsEvents) InitialStateAsEvents else InitialStateAsSnapshot
     PekkoCluster(context.system).subscribe(self, initialState, classOf[ClusterDomainEvent])
 

diff --git a/zio-pekko-cluster/src/main/scala/zio/pekko/cluster/pubsub/PubSub.scala b/zio-pekko-cluster/src/main/scala/zio/pekko/cluster/pubsub/PubSub.scala
@@ -1,9 +1,9 @@
 package zio.pekko.cluster.pubsub
 
-import zio.{ Queue, Task, ZIO }
-import zio.pekko.cluster.pubsub.impl.{ PublisherImpl, SubscriberImpl }
+import zio._
+import zio.pekko.cluster.pubsub.impl._
 
-import org.apache.pekko.actor.{ ActorRef, ActorSystem }
+import org.apache.pekko.actor._
 import org.apache.pekko.cluster.pubsub.DistributedPubSub
 
 /**

diff --git a/zio-pekko-cluster/src/main/scala/zio/pekko/cluster/pubsub/impl/PublisherImpl.scala b/zio-pekko-cluster/src/main/scala/zio/pekko/cluster/pubsub/impl/PublisherImpl.scala
@@ -1,7 +1,7 @@
 package zio.pekko.cluster.pubsub.impl
 
-import zio.{ Task, ZIO }
-import zio.pekko.cluster.pubsub.{ MessageEnvelope, Publisher }
+import zio._
+import zio.pekko.cluster.pubsub._
 
 import org.apache.pekko.actor._
 import org.apache.pekko.cluster.pubsub.DistributedPubSubMediator.Publish

diff --git a/zio-pekko-cluster/src/main/scala/zio/pekko/cluster/pubsub/impl/SubscriberImpl.scala b/zio-pekko-cluster/src/main/scala/zio/pekko/cluster/pubsub/impl/SubscriberImpl.scala
@@ -1,10 +1,10 @@
 package zio.pekko.cluster.pubsub.impl
 
-import zio.{ Exit, Promise, Queue, Runtime, Task, Unsafe, ZIO }
-import zio.pekko.cluster.pubsub.{ MessageEnvelope, Subscriber }
+import zio._
+import zio.pekko.cluster.pubsub._
 
 import org.apache.pekko.actor._
-import org.apache.pekko.cluster.pubsub.DistributedPubSubMediator.{ Subscribe, SubscribeAck }
+import org.apache.pekko.cluster.pubsub.DistributedPubSubMediator._
 
 import SubscriberImpl.SubscriberActor
 

diff --git a/zio-pekko-cluster/src/main/scala/zio/pekko/cluster/sharding/package.scala b/zio-pekko-cluster/src/main/scala/zio/pekko/cluster/sharding/package.scala
@@ -2,7 +2,7 @@ package zio.pekko.cluster
 
 import scala.concurrent.duration.Duration
 
-import zio.{ Ref, Tag, Task, UIO, URIO, ZIO }
+import zio._
 
 import org.apache.pekko.actor.ActorContext
 

diff --git a/zio-pekko-cluster/src/test/scala/zio/pekko/cluster/pubsub/PubSubSpec.scala b/zio-pekko-cluster/src/test/scala/zio/pekko/cluster/pubsub/PubSubSpec.scala
@@ -1,12 +1,12 @@
 package zio.pekko.cluster.pubsub
 
-import zio.{ ExecutionStrategy, ZIO, ZLayer }
+import zio._
 import zio.test._
 import zio.test.Assertion._
 import zio.test.TestEnvironment
 import zio.test.ZIOSpecDefault
 
-import com.typesafe.config.{ Config, ConfigFactory }
+import com.typesafe.config._
 
 import org.apache.pekko.actor.ActorSystem
 

diff --git a/zio-pekko-cluster/src/test/scala/zio/pekko/cluster/sharding/ShardingSpec.scala b/zio-pekko-cluster/src/test/scala/zio/pekko/cluster/sharding/ShardingSpec.scala
@@ -3,7 +3,6 @@ package zio.pekko.cluster.sharding
 import scala.language.postfixOps
 
 import zio._
-import zio.{ ExecutionStrategy, Promise, UIO, ZIO, ZLayer }
 import zio.test._
 import zio.test.Assertion._
 import zio.test.TestEnvironment