diff --git a/src/main/kotlin/eventDemo/business/event/EventHandler.kt b/src/main/kotlin/eventDemo/business/event/EventHandler.kt index f3be01c..4a4340f 100644 --- a/src/main/kotlin/eventDemo/business/event/EventHandler.kt +++ b/src/main/kotlin/eventDemo/business/event/EventHandler.kt @@ -7,8 +7,6 @@ import eventDemo.libs.event.Event * A stream to publish and read the played card event. */ interface EventHandler, ID : AggregateId> { - fun registerProjectionBuilder(builder: (event: E) -> Unit) - suspend fun handle( aggregateId: ID, buildEvent: (version: Int) -> E, diff --git a/src/main/kotlin/eventDemo/business/event/GameEventHandler.kt b/src/main/kotlin/eventDemo/business/event/GameEventHandler.kt index ddabfa0..37d161f 100644 --- a/src/main/kotlin/eventDemo/business/event/GameEventHandler.kt +++ b/src/main/kotlin/eventDemo/business/event/GameEventHandler.kt @@ -5,7 +5,6 @@ import eventDemo.business.event.event.GameEvent import eventDemo.libs.event.VersionBuilder import io.github.oshai.kotlinlogging.withLoggingContext import java.util.concurrent.ConcurrentHashMap -import java.util.concurrent.ConcurrentLinkedQueue import java.util.concurrent.locks.ReentrantLock import kotlin.concurrent.withLock @@ -17,13 +16,8 @@ class GameEventHandler( private val eventStore: GameEventStore, private val versionBuilder: VersionBuilder, ) : EventHandler { - private val projectionsBuilders: ConcurrentLinkedQueue<(GameEvent) -> Unit> = ConcurrentLinkedQueue() private val locks: ConcurrentHashMap = ConcurrentHashMap() - override fun registerProjectionBuilder(builder: (event: GameEvent) -> Unit) { - projectionsBuilders.add(builder) - } - /** * Build Event then send it to the event store and bus. */