Cross Scala Versions

davenverse · Jan 5, 2022 · aced191 · aced191
1 parent 46fe0a0
commit aced191
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/core/src/main/scala/io/chrisdavenport/rediculous/RedisCommands.scala b/core/src/main/scala/io/chrisdavenport/rediculous/RedisCommands.scala
@@ -198,7 +198,7 @@ object RedisCommands {
   // TODO Scan
   // TODO LEX
 
-    sealed trait Trimming
+  sealed trait Trimming
   object Trimming {
     case object Approximate extends Trimming
     case object Exact extends Trimming
@@ -255,7 +255,7 @@ object RedisCommands {
     case class From(stream: String, offset: String) extends StreamOffset 
   }
 
-  case class StreamsRecord(
+  final case class StreamsRecord(
     recordId: String,
     keyValues: List[(String, String)]
   )
@@ -278,7 +278,7 @@ object RedisCommands {
     }
   }
 
-  case class XReadResponse(
+  final case class XReadResponse(
     stream: String,
     records: List[StreamsRecord]
   )

diff --git a/core/src/main/scala/io/chrisdavenport/rediculous/RedisStream.scala b/core/src/main/scala/io/chrisdavenport/rediculous/RedisStream.scala
@@ -13,7 +13,7 @@ trait RedisStream[F[_]] {
   def read(
     keys: Set[String],
     chunkSize: Int,
-    initialOffset: String => StreamOffset = StreamOffset.All,
+    initialOffset: String => StreamOffset = {(s: String) => StreamOffset.All(s)},
     block: Duration = Duration.Zero,
     count: Option[Long] = None
   ): Stream[F, RedisCommands.XReadResponse]

diff --git a/examples/src/main/scala/StreamsExample.scala b/examples/src/main/scala/StreamsExample.scala
@@ -55,7 +55,7 @@ object StreamProducerExample extends IOApp {
         val consumer = rs
           .read(Set(mystream), 10000)
           .evalMap(putStrLn)
-          .onError(err => Stream.exec(IO.println(s"Consumer err: $err")))
+          .onError{ case err => Stream.exec(IO.println(s"Consumer err: $err"))}
           .logAverageRate(rate => IO.println(s"Consumer rate: $rate/s"))
 
         val producer = 
@@ -66,7 +66,7 @@ object StreamProducerExample extends IOApp {
             .flatMap{ chunk => 
               Stream.evalSeq(rs.append(chunk.toList))
             }
-            .onError(err => Stream.exec(IO.println(s"Producer err: $err")))
+            .onError{ case err => Stream.exec(IO.println(s"Producer err: $err"))}
             .logAverageRate(rate => IO.println(s"Producer rate: $rate/s"))
 
         val stream =