internal components

rodolfodpk · Jan 11, 2025 · ce27dc3 · ce27dc3
1 parent e54ff54
commit ce27dc3
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/main/kotlin/crablet/query/impl/SubscriptionComponent.kt b/src/main/kotlin/crablet/query/impl/SubscriptionComponent.kt
@@ -8,7 +8,7 @@ import io.vertx.sqlclient.Pool
 import io.vertx.sqlclient.SqlConnection
 import io.vertx.sqlclient.Tuple
 
-class SubscriptionComponent(
+internal class SubscriptionComponent(
     private val pool: Pool,
 ) {
     fun handlePendingEvents(subscriptionConfig: SubscriptionConfig): Future<Pair<Long, Int>> {

diff --git a/src/main/kotlin/crablet/query/impl/SubscriptionVerticle.kt b/src/main/kotlin/crablet/query/impl/SubscriptionVerticle.kt
@@ -10,7 +10,7 @@ import java.util.concurrent.atomic.AtomicBoolean
 import java.util.concurrent.atomic.AtomicLong
 import kotlin.math.min
 
-class SubscriptionVerticle(
+internal class SubscriptionVerticle(
     private val subscriptionConfig: SubscriptionConfig,
     private val subscriptionComponent: SubscriptionComponent,
     private val intervalConfig: IntervalConfig,