Org. imports to get rid of *

asomov · guenhter · commit 46a3cc78819e · 2020-03-24T16:26:32.000+01:00
diff --git a/examples/src/main/java/actor/proto/examples/java/helloworld/Hello.java b/examples/src/main/java/actor/proto/examples/java/helloworld/Hello.java
@@ -5,7 +5,9 @@
 import java.io.IOException;
 
 import static actor.proto.Protos.PID;
-import static actor.proto.java.Actors.*;
+import static actor.proto.java.Actors.fromProducer;
+import static actor.proto.java.Actors.send;
+import static actor.proto.java.Actors.spawn;
 
 public class Hello {
     public static void main(String[] args) throws IOException {
diff --git a/examples/src/main/java/actor/proto/examples/java/helloworld/HelloActor.java b/examples/src/main/java/actor/proto/examples/java/helloworld/HelloActor.java
@@ -4,7 +4,9 @@
 import actor.proto.java.Actor;
 import actor.proto.java.Context;
 import org.jetbrains.annotations.NotNull;
+
 import java.util.concurrent.CompletableFuture;
+
 import static actor.proto.java.Actors.done;
 
 class HelloActor implements Actor {
diff --git a/proto-actor/src/main/kotlin/actor/proto/DeferredProcess.kt b/proto-actor/src/main/kotlin/actor/proto/DeferredProcess.kt
@@ -4,7 +4,6 @@ import actor.proto.mailbox.SystemMessage
 import kotlinx.coroutines.CompletableDeferred
 import kotlinx.coroutines.withTimeout
 import java.time.Duration
-import java.util.concurrent.TimeUnit
 
 class DeferredProcess<out T>(private val timeout: Duration = Duration.ofMillis(5000)) : Process() {
     val pid = ProcessRegistry.put(ProcessRegistry.nextId(), this)
diff --git a/proto-actor/src/main/kotlin/actor/proto/java/API.kt b/proto-actor/src/main/kotlin/actor/proto/java/API.kt
@@ -3,7 +3,11 @@
 
 package actor.proto.java
 
-import actor.proto.*
+import actor.proto.DefaultActorClient
+import actor.proto.PID
+import actor.proto.ProcessRegistry
+import actor.proto.Props
+import actor.proto.spawn
 import kotlinx.coroutines.GlobalScope
 import kotlinx.coroutines.async
 import kotlinx.coroutines.future.asCompletableFuture
diff --git a/proto-actor/src/main/kotlin/actor/proto/java/ContextImpl.kt b/proto-actor/src/main/kotlin/actor/proto/java/ContextImpl.kt
@@ -2,9 +2,10 @@ package actor.proto.java
 
 import actor.proto.PID
 import actor.proto.Props
-import kotlinx.coroutines.*
+import kotlinx.coroutines.GlobalScope
+import kotlinx.coroutines.async
 import kotlinx.coroutines.future.asCompletableFuture
-
+import kotlinx.coroutines.runBlocking
 import java.time.Duration
 import java.util.concurrent.CompletableFuture
 
diff --git a/proto-actor/src/test/kotlin/actor/proto/mailbox/MailboxSchedulingTests.kt b/proto-actor/src/test/kotlin/actor/proto/mailbox/MailboxSchedulingTests.kt
@@ -3,7 +3,9 @@ package actor.proto.mailbox
 import actor.proto.fixture.TestMailboxHandler
 import actor.proto.fixture.TestMessage
 import actor.proto.fixture.TestSystemMessage
-import org.junit.jupiter.api.Assertions.*
+import org.junit.jupiter.api.Assertions.assertEquals
+import org.junit.jupiter.api.Assertions.assertFalse
+import org.junit.jupiter.api.Assertions.assertTrue
 import org.junit.jupiter.api.Test
 import java.util.concurrent.ConcurrentLinkedQueue
 
diff --git a/proto-actor/src/test/kotlin/actor/proto/mailbox/MailboxStatisticsTests.kt b/proto-actor/src/test/kotlin/actor/proto/mailbox/MailboxStatisticsTests.kt
@@ -1,6 +1,10 @@
 package actor.proto.mailbox
 
-import actor.proto.fixture.*
+import actor.proto.fixture.ExceptionalMessage
+import actor.proto.fixture.ExceptionalSystemMessage
+import actor.proto.fixture.TestMailboxHandler
+import actor.proto.fixture.TestMailboxStatistics
+import actor.proto.fixture.TestMessage
 import org.junit.jupiter.api.Assertions.assertFalse
 import org.junit.jupiter.api.Assertions.assertTrue
 import org.junit.jupiter.api.Test
diff --git a/proto-actor/src/test/kotlin/actor/proto/tests/ActorTests.kt b/proto-actor/src/test/kotlin/actor/proto/tests/ActorTests.kt
@@ -1,8 +1,18 @@
 package actor.proto.tests
 
-import actor.proto.*
+import actor.proto.Context
+import actor.proto.PID
+import actor.proto.Restarting
+import actor.proto.Started
+import actor.proto.Stopped
+import actor.proto.Stopping
 import actor.proto.fixture.EmptyReceive
 import actor.proto.fixture.TestMailbox
+import actor.proto.fromFunc
+import actor.proto.requestAwait
+import actor.proto.send
+import actor.proto.spawn
+import actor.proto.stop
 import kotlinx.coroutines.CancellationException
 import kotlinx.coroutines.runBlocking
 import org.awaitility.Awaitility
diff --git a/proto-actor/src/test/kotlin/actor/proto/tests/BehaviorTests.kt b/proto-actor/src/test/kotlin/actor/proto/tests/BehaviorTests.kt
@@ -1,6 +1,14 @@
 package actor.proto.tests
 
-import actor.proto.*
+import actor.proto.Actor
+import actor.proto.Behavior
+import actor.proto.Context
+import actor.proto.PID
+import actor.proto.Props
+import actor.proto.fromFunc
+import actor.proto.fromProducer
+import actor.proto.requestAwait
+import actor.proto.spawn
 import kotlinx.coroutines.runBlocking
 import org.junit.jupiter.api.Assertions.assertEquals
 import org.junit.jupiter.api.Test
diff --git a/proto-actor/src/test/kotlin/actor/proto/tests/LocalContextTests.kt b/proto-actor/src/test/kotlin/actor/proto/tests/LocalContextTests.kt
@@ -4,7 +4,9 @@ import actor.proto.Actor
 import actor.proto.ActorContext
 import actor.proto.PID
 import actor.proto.fixture.DoNothingSupervisorStrategy
-import org.junit.jupiter.api.Assertions.*
+import org.junit.jupiter.api.Assertions.assertEquals
+import org.junit.jupiter.api.Assertions.assertNotNull
+import org.junit.jupiter.api.Assertions.assertNull
 import org.junit.jupiter.api.Test
 import java.time.Duration
 
diff --git a/proto-actor/src/test/kotlin/actor/proto/tests/MiddlewareTests.kt b/proto-actor/src/test/kotlin/actor/proto/tests/MiddlewareTests.kt
@@ -1,8 +1,14 @@
 package actor.proto.tests
 
-import actor.proto.*
+import actor.proto.Props
 import actor.proto.fixture.DoNothingActor
 import actor.proto.fixture.TestMailbox
+import actor.proto.fromFunc
+import actor.proto.fromProducer
+import actor.proto.send
+import actor.proto.spawn
+import actor.proto.withReceiveMiddleware
+import actor.proto.withSenderMiddleware
 import org.junit.jupiter.api.Assertions.assertEquals
 import org.junit.jupiter.api.Test
 
diff --git a/proto-actor/src/test/kotlin/actor/proto/tests/PIDTests.kt b/proto-actor/src/test/kotlin/actor/proto/tests/PIDTests.kt
@@ -1,10 +1,16 @@
 package actor.proto.tests
 
-import actor.proto.*
+import actor.proto.PID
+import actor.proto.ProcessRegistry
+import actor.proto.cachedProcess
 import actor.proto.fixture.EmptyReceive
 import actor.proto.fixture.TestMailbox
 import actor.proto.fixture.TestProcess
-import org.junit.jupiter.api.Assertions.*
+import actor.proto.fromFunc
+import actor.proto.spawn
+import actor.proto.stop
+import org.junit.jupiter.api.Assertions.assertNotNull
+import org.junit.jupiter.api.Assertions.assertSame
 import org.junit.jupiter.api.Test
 import java.util.*
 
diff --git a/proto-actor/src/test/kotlin/actor/proto/tests/PropsTests.kt b/proto-actor/src/test/kotlin/actor/proto/tests/PropsTests.kt
@@ -1,10 +1,15 @@
 package actor.proto.tests
 
-import actor.proto.*
+import actor.proto.Actor
+import actor.proto.Context
+import actor.proto.PID
+import actor.proto.Props
 import actor.proto.fixture.DoNothingSupervisorStrategy
 import actor.proto.fixture.TestDispatcher
 import actor.proto.fixture.TestMailbox
 import actor.proto.mailbox.Mailbox
+import actor.proto.withProducer
+import actor.proto.withSpawner
 import org.junit.jupiter.api.Assertions.assertEquals
 import org.junit.jupiter.api.Assertions.assertNotEquals
 import org.junit.jupiter.api.Test
diff --git a/proto-actor/src/test/kotlin/actor/proto/tests/ReceiveTimeoutTests.kt b/proto-actor/src/test/kotlin/actor/proto/tests/ReceiveTimeoutTests.kt
@@ -1,6 +1,10 @@
 package actor.proto.tests
 
-import actor.proto.*
+import actor.proto.Props
+import actor.proto.ReceiveTimeout
+import actor.proto.Started
+import actor.proto.fromFunc
+import actor.proto.spawn
 import org.junit.jupiter.api.Test
 import java.time.Duration
 import java.util.concurrent.CountDownLatch
diff --git a/proto-actor/src/test/kotlin/actor/proto/tests/SpawnTests.kt b/proto-actor/src/test/kotlin/actor/proto/tests/SpawnTests.kt
@@ -1,7 +1,11 @@
 package actor.proto.tests
 
-import actor.proto.*
+import actor.proto.PID
+import actor.proto.Props
 import actor.proto.fixture.EmptyReceive
+import actor.proto.fromFunc
+import actor.proto.spawn
+import actor.proto.withSpawner
 import org.junit.jupiter.api.Assertions.assertSame
 import org.junit.jupiter.api.Test
 
diff --git a/proto-actor/src/test/kotlin/actor/proto/tests/SupervisionTests_AllForOne.kt b/proto-actor/src/test/kotlin/actor/proto/tests/SupervisionTests_AllForOne.kt
@@ -1,10 +1,25 @@
 package actor.proto.tests
 
-import actor.proto.*
+import actor.proto.Actor
+import actor.proto.AllForOneStrategy
+import actor.proto.Context
+import actor.proto.Failure
+import actor.proto.PID
+import actor.proto.Props
+import actor.proto.Restart
+import actor.proto.Started
+import actor.proto.StopInstance
+import actor.proto.Stopped
+import actor.proto.SupervisorDirective
 import actor.proto.fixture.TestMailboxStatistics
+import actor.proto.fromProducer
 import actor.proto.mailbox.ResumeMailbox
 import actor.proto.mailbox.newUnboundedMailbox
-import org.junit.jupiter.api.Assertions.*
+import actor.proto.send
+import actor.proto.spawn
+import org.junit.jupiter.api.Assertions.assertEquals
+import org.junit.jupiter.api.Assertions.assertFalse
+import org.junit.jupiter.api.Assertions.assertTrue
 import org.junit.jupiter.api.Test
 import java.util.concurrent.TimeUnit
 
diff --git a/proto-actor/src/test/kotlin/actor/proto/tests/SupervisionTests_OneForOne.kt b/proto-actor/src/test/kotlin/actor/proto/tests/SupervisionTests_OneForOne.kt
@@ -1,9 +1,22 @@
 package actor.proto.tests
 
-import actor.proto.*
+import actor.proto.Actor
+import actor.proto.Context
+import actor.proto.Failure
+import actor.proto.OneForOneStrategy
+import actor.proto.PID
+import actor.proto.Props
+import actor.proto.Restart
+import actor.proto.Started
+import actor.proto.StopInstance
+import actor.proto.Stopped
+import actor.proto.SupervisorDirective
 import actor.proto.fixture.TestMailboxStatistics
+import actor.proto.fromProducer
 import actor.proto.mailbox.ResumeMailbox
 import actor.proto.mailbox.newUnboundedMailbox
+import actor.proto.send
+import actor.proto.spawn
 import org.junit.jupiter.api.Assertions.assertEquals
 import org.junit.jupiter.api.Assertions.assertTrue
 import org.junit.jupiter.api.Test
diff --git a/proto-actor/src/test/kotlin/actor/proto/tests/WatchTests.kt b/proto-actor/src/test/kotlin/actor/proto/tests/WatchTests.kt
@@ -1,11 +1,18 @@
 package actor.proto.tests
 
-import actor.proto.*
+import actor.proto.Actor
+import actor.proto.Context
+import actor.proto.PID
+import actor.proto.Started
+import actor.proto.Terminated
 import actor.proto.fixture.DoNothingActor
 import actor.proto.fixture.TestMailbox
+import actor.proto.fromProducer
+import actor.proto.requestAwait
+import actor.proto.spawn
+import actor.proto.stop
 import kotlinx.coroutines.runBlocking
 import org.junit.jupiter.api.Assertions.assertTrue
-
 import org.junit.jupiter.api.Test
 import java.time.Duration
 
diff --git a/proto-mailbox/src/main/kotlin/actor/proto/mailbox/DefaultDispatcher.kt b/proto-mailbox/src/main/kotlin/actor/proto/mailbox/DefaultDispatcher.kt
@@ -1,9 +1,9 @@
 package actor.proto.mailbox
 
-import kotlinx.coroutines.launch
 import kotlinx.coroutines.CoroutineScope
 import kotlinx.coroutines.Dispatchers
 import kotlinx.coroutines.SupervisorJob
+import kotlinx.coroutines.launch
 import kotlinx.coroutines.plus
 import kotlin.coroutines.CoroutineContext
 
diff --git a/proto-mailbox/src/main/kotlin/actor/proto/mailbox/MailboxProducers.kt b/proto-mailbox/src/main/kotlin/actor/proto/mailbox/MailboxProducers.kt
@@ -1,8 +1,13 @@
 package actor.proto.mailbox
 
-import org.jctools.queues.*
+import org.jctools.queues.MpscArrayQueue
+import org.jctools.queues.MpscGrowableArrayQueue
+import org.jctools.queues.MpscLinkedQueue8
+import org.jctools.queues.MpscUnboundedArrayQueue
 import org.jctools.queues.QueueFactory.newQueue
-import org.jctools.queues.atomic.*
+import org.jctools.queues.atomic.MpscAtomicArrayQueue
+import org.jctools.queues.atomic.MpscGrowableAtomicArrayQueue
+import org.jctools.queues.atomic.MpscUnboundedAtomicArrayQueue
 import org.jctools.queues.spec.ConcurrentQueueSpec
 import java.util.concurrent.ConcurrentLinkedQueue
 
diff --git a/proto-mailbox/src/test/kotlin/actor/proto/mailbox/DefaultDispatcherTest.kt b/proto-mailbox/src/test/kotlin/actor/proto/mailbox/DefaultDispatcherTest.kt
@@ -3,9 +3,9 @@ package actor.proto.mailbox
 import kotlinx.coroutines.asCoroutineDispatcher
 import kotlinx.coroutines.delay
 import org.awaitility.Awaitility
-import org.junit.jupiter.api.Assertions.assertTrue
 import org.junit.jupiter.api.Assertions.assertNotSame
 import org.junit.jupiter.api.Assertions.assertSame
+import org.junit.jupiter.api.Assertions.assertTrue
 import org.junit.jupiter.api.Test
 import java.util.concurrent.Executors
 import java.util.concurrent.TimeUnit
diff --git a/proto-remote/src/main/java/actor/proto/remote/RemotingGrpc.java b/proto-remote/src/main/java/actor/proto/remote/RemotingGrpc.java
@@ -3,10 +3,12 @@
 import static io.grpc.MethodDescriptor.generateFullMethodName;
 import static io.grpc.stub.ClientCalls.asyncBidiStreamingCall;
 import static io.grpc.stub.ClientCalls.asyncUnaryCall;
-import static io.grpc.stub.ClientCalls.*;
+import static io.grpc.stub.ClientCalls.blockingUnaryCall;
+import static io.grpc.stub.ClientCalls.futureUnaryCall;
 import static io.grpc.stub.ServerCalls.asyncBidiStreamingCall;
 import static io.grpc.stub.ServerCalls.asyncUnaryCall;
-import static io.grpc.stub.ServerCalls.*;
+import static io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall;
+import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;
 
 /**
  */
diff --git a/proto-remote/src/main/kotlin/actor/proto/remote/Activator.kt b/proto-remote/src/main/kotlin/actor/proto/remote/Activator.kt
@@ -1,6 +1,11 @@
 package actor.proto.remote
 
-import actor.proto.*
+import actor.proto.Actor
+import actor.proto.Context
+import actor.proto.PID
+import actor.proto.ProcessRegistry
+import actor.proto.Props
+import actor.proto.spawnNamed
 
 
 class Activator : Actor {
diff --git a/proto-remote/src/main/kotlin/actor/proto/remote/EndpointManager.kt b/proto-remote/src/main/kotlin/actor/proto/remote/EndpointManager.kt
@@ -1,6 +1,14 @@
 package actor.proto.remote
 
-import actor.proto.*
+import actor.proto.Actor
+import actor.proto.Context
+import actor.proto.PID
+import actor.proto.Props
+import actor.proto.RestartStatistics
+import actor.proto.Started
+import actor.proto.Supervisor
+import actor.proto.SupervisorStrategy
+import actor.proto.fromProducer
 import mu.KotlinLogging
 
 private val logger = KotlinLogging.logger {}
diff --git a/proto-remote/src/main/kotlin/actor/proto/remote/EndpointReader.kt b/proto-remote/src/main/kotlin/actor/proto/remote/EndpointReader.kt
@@ -1,7 +1,12 @@
 package actor.proto.remote
 
-import actor.proto.*
+import actor.proto.PID
+import actor.proto.ProcessRegistry
+import actor.proto.Terminated
 import actor.proto.mailbox.SystemMessage
+import actor.proto.request
+import actor.proto.send
+import actor.proto.sendSystemMessage
 import io.grpc.stub.StreamObserver
 import mu.KotlinLogging
 
diff --git a/proto-remote/src/main/kotlin/actor/proto/remote/EndpointWatcher.kt b/proto-remote/src/main/kotlin/actor/proto/remote/EndpointWatcher.kt
@@ -1,6 +1,14 @@
 package actor.proto.remote
 
-import actor.proto.*
+import actor.proto.Actor
+import actor.proto.Behavior
+import actor.proto.Context
+import actor.proto.PID
+import actor.proto.ProcessRegistry
+import actor.proto.Terminated
+import actor.proto.Unwatch
+import actor.proto.Watch
+import actor.proto.sendSystemMessage
 
 class EndpointWatcher(address: String) : Actor {
     private val behavior: Behavior = Behavior({ connectedAsync(it) })
diff --git a/proto-remote/src/main/kotlin/actor/proto/remote/EndpointWriter.kt b/proto-remote/src/main/kotlin/actor/proto/remote/EndpointWriter.kt
@@ -1,6 +1,11 @@
 package actor.proto.remote
 
-import actor.proto.*
+import actor.proto.Actor
+import actor.proto.Context
+import actor.proto.EventStream
+import actor.proto.Restarting
+import actor.proto.Started
+import actor.proto.Stopped
 import com.google.protobuf.ByteString
 import io.grpc.ManagedChannel
 import io.grpc.ManagedChannelBuilder
diff --git a/proto-remote/src/main/kotlin/actor/proto/remote/EndpointWriterMailbox.kt b/proto-remote/src/main/kotlin/actor/proto/remote/EndpointWriterMailbox.kt
diff --git a/proto-remote/src/main/kotlin/actor/proto/remote/Remote.kt b/proto-remote/src/main/kotlin/actor/proto/remote/Remote.kt
diff --git a/proto-remote/src/main/kotlin/actor/proto/remote/RemoteProcess.kt b/proto-remote/src/main/kotlin/actor/proto/remote/RemoteProcess.kt
diff --git a/proto-router/src/main/kotlin/actor/proto/router/GroupRouterConfig.kt b/proto-router/src/main/kotlin/actor/proto/router/GroupRouterConfig.kt
diff --git a/proto-router/src/main/kotlin/actor/proto/router/PoolRouterConfig.kt b/proto-router/src/main/kotlin/actor/proto/router/PoolRouterConfig.kt
diff --git a/proto-router/src/main/kotlin/actor/proto/router/Router.kt b/proto-router/src/main/kotlin/actor/proto/router/Router.kt
diff --git a/proto-router/src/main/kotlin/actor/proto/router/RouterActor.kt b/proto-router/src/main/kotlin/actor/proto/router/RouterActor.kt
diff --git a/proto-router/src/main/kotlin/actor/proto/router/RouterConfig.kt b/proto-router/src/main/kotlin/actor/proto/router/RouterConfig.kt
diff --git a/proto-router/src/test/kotlin/actor/proto/router/tests/BroadcastGroupTests.kt b/proto-router/src/test/kotlin/actor/proto/router/tests/BroadcastGroupTests.kt
diff --git a/proto-router/src/test/kotlin/actor/proto/router/tests/PoolRouterTests.kt b/proto-router/src/test/kotlin/actor/proto/router/tests/PoolRouterTests.kt
