From 96469b689ff9361a11ef46cc145e05f950952cd4 Mon Sep 17 00:00:00 2001
From: Fabrice Lecomte <fabrice.lecomte.be@gmail.com>
Date: Sun, 30 Mar 2025 03:06:25 +0200
Subject: [PATCH] remove projectionsBuilders method

---
 src/main/kotlin/eventDemo/business/event/EventHandler.kt    | 2 --
 .../kotlin/eventDemo/business/event/GameEventHandler.kt     | 6 ------
 2 files changed, 8 deletions(-)

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<E : Event<ID>, 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<GameEvent, GameId> {
-  private val projectionsBuilders: ConcurrentLinkedQueue<(GameEvent) -> Unit> = ConcurrentLinkedQueue()
   private val locks: ConcurrentHashMap<GameId, ReentrantLock> = ConcurrentHashMap()
 
-  override fun registerProjectionBuilder(builder: (event: GameEvent) -> Unit) {
-    projectionsBuilders.add(builder)
-  }
-
   /**
    * Build Event then send it to the event store and bus.
    */