address pr review

laserdisc-io · Dec 30, 2020 · 4674617 · 4674617
1 parent e8f6b91
commit 4674617
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/core/src/main/scala/tamer/Setup.scala b/core/src/main/scala/tamer/Setup.scala
@@ -8,5 +8,5 @@ abstract class Setup[-K, -V, S](
     val valueSerializer: Serializer[Registry with Topic, V],
     val stateSerde: ZSerde[Registry with Topic, S],
     val defaultState: S,
-    val queryHash: Int
+    val stateKey: Int
 )
diff --git a/core/src/main/scala/tamer/kafka/Kafka.scala b/core/src/main/scala/tamer/kafka/Kafka.scala
@@ -77,7 +77,7 @@ object Kafka {
             sp: Producer.Service[Registry with Topic, StateKey, State],
             layer: ULayer[Registry with Topic]
         ) =
-          ZStream.fromEffect(logTask <*> UIO(StateKey(setup.queryHash.toHexString, cfg.state.groupId))).flatMap { // TODO: no need for UIO, it's pure
+          ZStream.fromEffect(logTask <*> UIO(StateKey(setup.stateKey.toHexString, cfg.state.groupId))).flatMap { // TODO: no need for UIO, it's pure
             case (log, stateKey) =>
               ZStream
                 .fromEffect(subscribe(sc))

diff --git a/doobie/src/main/scala/tamer/db/Db.scala b/doobie/src/main/scala/tamer/db/Db.scala
@@ -10,7 +10,7 @@ object Db {
 
   /** By specifying a field here, tamer will order database records according
     * to this date. Usually you want your latest update timestamp here.
-    * @param timestamp the value tamer will use to order the record by.
+    * @param timestamp the value tamer will use to order the records by.
     */
   abstract class Timestamped(val timestamp: Instant)
   object Timestamped {