Skip to content

Commit cacf703

Browse files
m-kalaim-kalai
authored
Expose Redis operations via Redis trait (zio#727)
1 parent bfff9ee commit cacf703

File tree

94 files changed

+3980
-2705
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

94 files changed

+3980
-2705
lines changed

‎README.md

+7-6
Original file line numberDiff line numberDiff line change
@@ -51,12 +51,13 @@ import zio.schema.codec._
5151

5252
object ZIORedisExample extends ZIOAppDefault {
5353
val myApp: ZIO[Redis, RedisError, Unit] = for {
54-
_ <- set("myKey", 8L, Some(1.minutes))
55-
v <- get("myKey").returning[Long]
56-
_ <- Console.printLine(s"Value of myKey: $v").orDie
57-
_ <- hSet("myHash", ("k1", 6), ("k2", 2))
58-
_ <- rPush("myList", 1, 2, 3, 4)
59-
_ <- sAdd("mySet", "a", "b", "a", "c")
54+
redis <- ZIO.service[Redis]
55+
_ <- redis.set("myKey", 8L, Some(1.minutes))
56+
v <- redis.get("myKey").returning[Long]
57+
_ <- Console.printLine(s"Value of myKey: $v").orDie
58+
_ <- redis.hSet("myHash", ("k1", 6), ("k2", 2))
59+
_ <- redis.rPush("myList", 1, 2, 3, 4)
60+
_ <- redis.sAdd("mySet", "a", "b", "a", "c")
6061
} yield ()
6162

6263
override def run = myApp.provide(

‎benchmarks/src/main/scala/zio/redis/benchmarks/hash/HDelBenchmarks.scala

+2-2
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ class HDelBenchmarks extends BenchmarkRuntime {
4040
@Setup(Level.Trial)
4141
def setup(): Unit = {
4242
items = (0 to size).map(e => e.toString -> e.toString).toList
43-
execute(hSet(key, items.head, items.tail: _*).unit)
43+
execute(ZIO.serviceWithZIO[Redis](_.hSet(key, items.head, items.tail: _*).unit))
4444
}
4545

4646
@Benchmark
@@ -67,5 +67,5 @@ class HDelBenchmarks extends BenchmarkRuntime {
6767
}
6868

6969
@Benchmark
70-
def zio(): Unit = execute(ZIO.foreachDiscard(items)(it => hDel(key, it._1)))
70+
def zio(): Unit = execute(ZIO.foreachDiscard(items)(it => ZIO.serviceWithZIO[Redis](_.hDel(key, it._1))))
7171
}

‎benchmarks/src/main/scala/zio/redis/benchmarks/hash/HExistsBenchmarks.scala

+2-2
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ class HExistsBenchmarks extends BenchmarkRuntime {
4040
@Setup(Level.Trial)
4141
def setup(): Unit = {
4242
items = (0 to size).map(e => e.toString -> e.toString).toList
43-
execute(hSet(key, items.head, items.tail: _*).unit)
43+
execute(ZIO.serviceWithZIO[Redis](_.hSet(key, items.head, items.tail: _*).unit))
4444
}
4545

4646
@Benchmark
@@ -69,5 +69,5 @@ class HExistsBenchmarks extends BenchmarkRuntime {
6969
}
7070

7171
@Benchmark
72-
def zio(): Unit = execute(ZIO.foreachDiscard(items)(it => hExists(key, it._1)))
72+
def zio(): Unit = execute(ZIO.foreachDiscard(items)(it => ZIO.serviceWithZIO[Redis](_.hExists(key, it._1))))
7373
}

‎benchmarks/src/main/scala/zio/redis/benchmarks/hash/HGetAllBenchmarks.scala

+4-2
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ class HGetAllBenchmarks extends BenchmarkRuntime {
4040
@Setup(Level.Trial)
4141
def setup(): Unit = {
4242
items = (0 to size).map(e => e.toString -> e.toString).toList
43-
execute(hSet(key, items.head, items.tail: _*).unit)
43+
execute(ZIO.serviceWithZIO[Redis](_.hSet(key, items.head, items.tail: _*).unit))
4444
}
4545

4646
@Benchmark
@@ -67,5 +67,7 @@ class HGetAllBenchmarks extends BenchmarkRuntime {
6767
}
6868

6969
@Benchmark
70-
def zio(): Unit = execute(ZIO.foreachDiscard(items)(_ => hGetAll(key).returning[String, String]))
70+
def zio(): Unit = execute(
71+
ZIO.foreachDiscard(items)(_ => ZIO.serviceWithZIO[Redis](_.hGetAll(key).returning[String, String]))
72+
)
7173
}

‎benchmarks/src/main/scala/zio/redis/benchmarks/hash/HGetBenchmarks.scala

+4-2
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ class HGetBenchmarks extends BenchmarkRuntime {
4040
@Setup(Level.Trial)
4141
def setup(): Unit = {
4242
items = (0 to size).map(e => e.toString -> e.toString).toList
43-
execute(hSet(key, items.head, items.tail: _*).unit)
43+
execute(ZIO.serviceWithZIO[Redis](_.hSet(key, items.head, items.tail: _*).unit))
4444
}
4545

4646
@Benchmark
@@ -68,5 +68,7 @@ class HGetBenchmarks extends BenchmarkRuntime {
6868
}
6969

7070
@Benchmark
71-
def zio(): Unit = execute(ZIO.foreachDiscard(items)(it => hGet(key, it._1).returning[String]))
71+
def zio(): Unit = execute(
72+
ZIO.foreachDiscard(items)(it => ZIO.serviceWithZIO[Redis](_.hGet(key, it._1).returning[String]))
73+
)
7274
}

‎benchmarks/src/main/scala/zio/redis/benchmarks/hash/HIncrbyBenchmarks.scala

+4-2
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ class HIncrbyBenchmarks extends BenchmarkRuntime {
4343
@Setup(Level.Trial)
4444
def setup(): Unit = {
4545
items = (0 to size).map(e => e.toString -> e.toString).toList
46-
execute(hSet(key, items.head, items.tail: _*).unit)
46+
execute(ZIO.serviceWithZIO[Redis](_.hSet(key, items.head, items.tail: _*).unit))
4747
}
4848

4949
@Benchmark
@@ -73,5 +73,7 @@ class HIncrbyBenchmarks extends BenchmarkRuntime {
7373
}
7474

7575
@Benchmark
76-
def zio(): Unit = execute(ZIO.foreachDiscard(items)(it => hIncrBy(key, it._1, increment)))
76+
def zio(): Unit = execute(
77+
ZIO.foreachDiscard(items)(it => ZIO.serviceWithZIO[Redis](_.hIncrBy(key, it._1, increment)))
78+
)
7779
}

‎benchmarks/src/main/scala/zio/redis/benchmarks/hash/HIncrbyFloatBenchmarks.scala

+4-2
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ class HIncrbyFloatBenchmarks extends BenchmarkRuntime {
4343
@Setup(Level.Trial)
4444
def setup(): Unit = {
4545
items = (0 to size).map(e => e.toString -> e.toString).toList
46-
execute(hSet(key, items.head, items.tail: _*).unit)
46+
execute(ZIO.serviceWithZIO[Redis](_.hSet(key, items.head, items.tail: _*).unit))
4747
}
4848

4949
@Benchmark
@@ -75,5 +75,7 @@ class HIncrbyFloatBenchmarks extends BenchmarkRuntime {
7575
}
7676

7777
@Benchmark
78-
def zio(): Unit = execute(ZIO.foreachDiscard(items)(it => hIncrByFloat(key, it._1, increment)))
78+
def zio(): Unit = execute(
79+
ZIO.foreachDiscard(items)(it => ZIO.serviceWithZIO[Redis](_.hIncrByFloat(key, it._1, increment)))
80+
)
7981
}

‎benchmarks/src/main/scala/zio/redis/benchmarks/hash/HKeysBenchmarks.scala

+2-2
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ class HKeysBenchmarks extends BenchmarkRuntime {
4040
@Setup(Level.Trial)
4141
def setup(): Unit = {
4242
items = (0 to size).map(e => e.toString -> e.toString).toList
43-
execute(hSet(key, items.head, items.tail: _*).unit)
43+
execute(ZIO.serviceWithZIO[Redis](_.hSet(key, items.head, items.tail: _*).unit))
4444
}
4545

4646
@Benchmark
@@ -67,5 +67,5 @@ class HKeysBenchmarks extends BenchmarkRuntime {
6767
}
6868

6969
@Benchmark
70-
def zio(): Unit = execute(ZIO.foreachDiscard(items)(_ => hKeys(key).returning[String]))
70+
def zio(): Unit = execute(ZIO.foreachDiscard(items)(_ => ZIO.serviceWithZIO[Redis](_.hKeys(key).returning[String])))
7171
}

‎benchmarks/src/main/scala/zio/redis/benchmarks/hash/HLenBenchmarks.scala

+2-2
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ class HLenBenchmarks extends BenchmarkRuntime {
4040
@Setup(Level.Trial)
4141
def setup(): Unit = {
4242
items = (0 to size).map(e => e.toString -> e.toString).toList
43-
execute(hSet(key, items.head, items.tail: _*).unit)
43+
execute(ZIO.serviceWithZIO[Redis](_.hSet(key, items.head, items.tail: _*).unit))
4444
}
4545

4646
@Benchmark
@@ -67,5 +67,5 @@ class HLenBenchmarks extends BenchmarkRuntime {
6767
}
6868

6969
@Benchmark
70-
def zio(): Unit = execute(ZIO.foreachDiscard(items)(_ => hLen(key)))
70+
def zio(): Unit = execute(ZIO.foreachDiscard(items)(_ => ZIO.serviceWithZIO[Redis](_.hLen(key))))
7171
}

‎benchmarks/src/main/scala/zio/redis/benchmarks/hash/HMGetBenchmarks.scala

+4-2
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ class HMGetBenchmarks extends BenchmarkRuntime {
4040
@Setup(Level.Trial)
4141
def setup(): Unit = {
4242
items = (0 to size).map(e => e.toString -> e.toString).toList
43-
execute(hSet(key, items.head, items.tail: _*).unit)
43+
execute(ZIO.serviceWithZIO[Redis](_.hSet(key, items.head, items.tail: _*).unit))
4444
}
4545

4646
@Benchmark
@@ -68,5 +68,7 @@ class HMGetBenchmarks extends BenchmarkRuntime {
6868
}
6969

7070
@Benchmark
71-
def zio(): Unit = execute(ZIO.foreachDiscard(items)(it => hmGet(key, it._1).returning[String]))
71+
def zio(): Unit = execute(
72+
ZIO.foreachDiscard(items)(it => ZIO.serviceWithZIO[Redis](_.hmGet(key, it._1).returning[String]))
73+
)
7274
}

‎benchmarks/src/main/scala/zio/redis/benchmarks/hash/HMSetBenchmarks.scala

+1-1
Original file line numberDiff line numberDiff line change
@@ -66,5 +66,5 @@ class HMSetBenchmarks extends BenchmarkRuntime {
6666
}
6767

6868
@Benchmark
69-
def zio(): Unit = execute(ZIO.foreachDiscard(items)(it => hmSet(key, it)))
69+
def zio(): Unit = execute(ZIO.foreachDiscard(items)(it => ZIO.serviceWithZIO[Redis](_.hmSet(key, it))))
7070
}

‎benchmarks/src/main/scala/zio/redis/benchmarks/hash/HSetBenchmarks.scala

+1-1
Original file line numberDiff line numberDiff line change
@@ -66,5 +66,5 @@ class HSetBenchmarks extends BenchmarkRuntime {
6666
}
6767

6868
@Benchmark
69-
def zio(): Unit = execute(ZIO.foreachDiscard(items)(it => hSet(key, it)))
69+
def zio(): Unit = execute(ZIO.foreachDiscard(items)(it => ZIO.serviceWithZIO[Redis](_.hSet(key, it))))
7070
}

‎benchmarks/src/main/scala/zio/redis/benchmarks/hash/HSetNxBenchmarks.scala

+1-1
Original file line numberDiff line numberDiff line change
@@ -67,5 +67,5 @@ class HSetNxBenchmarks extends BenchmarkRuntime {
6767
}
6868

6969
@Benchmark
70-
def zio(): Unit = execute(ZIO.foreachDiscard(items)(it => hSetNx(key, it._1, it._2)))
70+
def zio(): Unit = execute(ZIO.foreachDiscard(items)(it => ZIO.serviceWithZIO[Redis](_.hSetNx(key, it._1, it._2))))
7171
}

‎benchmarks/src/main/scala/zio/redis/benchmarks/hash/HStrLenBenchmarks.scala

+2-2
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ class HStrLenBenchmarks extends BenchmarkRuntime {
3939

4040
def setup(): Unit = {
4141
items = (0 to size).map(e => e.toString -> e.toString).toList
42-
execute(hSet(key, items.head, items.tail: _*).unit)
42+
execute(ZIO.serviceWithZIO[Redis](_.hSet(key, items.head, items.tail: _*).unit))
4343
}
4444
@Benchmark
4545
def laserdisc(): Unit = {
@@ -66,5 +66,5 @@ class HStrLenBenchmarks extends BenchmarkRuntime {
6666
}
6767

6868
@Benchmark
69-
def zio(): Unit = execute(ZIO.foreachDiscard(items)(it => hStrLen(key, it._1)))
69+
def zio(): Unit = execute(ZIO.foreachDiscard(items)(it => ZIO.serviceWithZIO[Redis](_.hStrLen(key, it._1))))
7070
}

‎benchmarks/src/main/scala/zio/redis/benchmarks/hash/HValsBenchmarks.scala

+2-2
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ class HValsBenchmarks extends BenchmarkRuntime {
4040
@Setup(Level.Trial)
4141
def setup(): Unit = {
4242
items = (0 to size).map(e => e.toString -> e.toString).toList
43-
execute(hSet(key, items.head, items.tail: _*).unit)
43+
execute(ZIO.serviceWithZIO[Redis](_.hSet(key, items.head, items.tail: _*).unit))
4444
}
4545

4646
@Benchmark
@@ -67,5 +67,5 @@ class HValsBenchmarks extends BenchmarkRuntime {
6767
}
6868

6969
@Benchmark
70-
def zio(): Unit = execute(ZIO.foreachDiscard(items)(_ => hVals(key).returning[String]))
70+
def zio(): Unit = execute(ZIO.foreachDiscard(items)(_ => ZIO.serviceWithZIO[Redis](_.hVals(key).returning[String])))
7171
}

‎benchmarks/src/main/scala/zio/redis/benchmarks/lists/BlMoveBenchmarks.scala

+5-3
Original file line numberDiff line numberDiff line change
@@ -41,15 +41,17 @@ class BlMoveBenchmarks extends BenchmarkRuntime {
4141
@Setup(Level.Trial)
4242
def setup(): Unit = {
4343
items = (0 to count).toList.map(_.toString)
44-
execute(rPush(key, items.head, items.tail: _*).unit)
44+
execute(ZIO.serviceWithZIO[Redis](_.rPush(key, items.head, items.tail: _*).unit))
4545
}
4646

4747
@TearDown(Level.Trial)
4848
def tearDown(): Unit =
49-
execute(del(key).unit)
49+
execute(ZIO.serviceWithZIO[Redis](_.del(key).unit))
5050

5151
@Benchmark
5252
def zio(): Unit = execute(
53-
ZIO.foreachDiscard(items)(_ => blMove(key, key, Side.Left, Side.Right, 1.second).returning[String])
53+
ZIO.foreachDiscard(items)(_ =>
54+
ZIO.serviceWithZIO[Redis](_.blMove(key, key, Side.Left, Side.Right, 1.second).returning[String])
55+
)
5456
)
5557
}

‎benchmarks/src/main/scala/zio/redis/benchmarks/lists/BlPopBenchmarks.scala

+4-2
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ class BlPopBenchmarks extends BenchmarkRuntime {
4040
@Setup(Level.Invocation)
4141
def setup(): Unit = {
4242
items = (0 to count).toList.map(_.toString)
43-
execute(rPush(key, items.head, items.tail: _*).unit)
43+
execute(ZIO.serviceWithZIO[Redis](_.rPush(key, items.head, items.tail: _*).unit))
4444
}
4545

4646
@Benchmark
@@ -76,5 +76,7 @@ class BlPopBenchmarks extends BenchmarkRuntime {
7676
}
7777

7878
@Benchmark
79-
def zio(): Unit = execute(ZIO.foreachDiscard(items)(_ => blPop(key)(1.second).returning[String]))
79+
def zio(): Unit = execute(
80+
ZIO.foreachDiscard(items)(_ => ZIO.serviceWithZIO[Redis](_.blPop(key)(1.second).returning[String]))
81+
)
8082
}

‎benchmarks/src/main/scala/zio/redis/benchmarks/lists/BrPopBenchmarks.scala

+4-2
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ class BrPopBenchmarks extends BenchmarkRuntime {
4040
@Setup(Level.Invocation)
4141
def setup(): Unit = {
4242
items = (0 to count).toList.map(_.toString)
43-
execute(rPush(key, items.head, items.tail: _*).unit)
43+
execute(ZIO.serviceWithZIO[Redis](_.rPush(key, items.head, items.tail: _*).unit))
4444
}
4545

4646
@Benchmark
@@ -76,5 +76,7 @@ class BrPopBenchmarks extends BenchmarkRuntime {
7676
}
7777

7878
@Benchmark
79-
def zio(): Unit = execute(ZIO.foreachDiscard(items)(_ => brPop(key)(1.second).returning[String]))
79+
def zio(): Unit = execute(
80+
ZIO.foreachDiscard(items)(_ => ZIO.serviceWithZIO[Redis](_.brPop(key)(1.second).returning[String]))
81+
)
8082
}

‎benchmarks/src/main/scala/zio/redis/benchmarks/lists/BrPopLPushBenchmarks.scala

+3-3
Original file line numberDiff line numberDiff line change
@@ -40,12 +40,12 @@ class BrPopLPushBenchmarks extends BenchmarkRuntime {
4040
@Setup(Level.Trial)
4141
def setup(): Unit = {
4242
items = (0 to count).toList.map(_.toString)
43-
execute(rPush(key, items.head, items.tail: _*).unit)
43+
execute(ZIO.serviceWithZIO[Redis](_.rPush(key, items.head, items.tail: _*).unit))
4444
}
4545

4646
@TearDown(Level.Trial)
4747
def tearDown(): Unit =
48-
execute(del(key).unit)
48+
execute(ZIO.serviceWithZIO[Redis](_.del(key).unit))
4949

5050
@Benchmark
5151
def laserdisc(): Unit = {
@@ -82,6 +82,6 @@ class BrPopLPushBenchmarks extends BenchmarkRuntime {
8282

8383
@Benchmark
8484
def zio(): Unit = execute(
85-
ZIO.foreachDiscard(items)(_ => brPopLPush(key, key, 1.second).returning[String])
85+
ZIO.foreachDiscard(items)(_ => ZIO.serviceWithZIO[Redis](_.brPopLPush(key, key, 1.second).returning[String]))
8686
)
8787
}

‎benchmarks/src/main/scala/zio/redis/benchmarks/lists/LIndexBenchmarks.scala

+5-3
Original file line numberDiff line numberDiff line change
@@ -40,12 +40,12 @@ class LIndexBenchmarks extends BenchmarkRuntime {
4040
@Setup(Level.Trial)
4141
def setup(): Unit = {
4242
items = (0 to count).toList
43-
execute(rPush(key, items.head, items.tail: _*).unit)
43+
execute(ZIO.serviceWithZIO[Redis](_.rPush(key, items.head, items.tail: _*).unit))
4444
}
4545

4646
@TearDown(Level.Trial)
4747
def tearDown(): Unit =
48-
execute(del(key).unit)
48+
execute(ZIO.serviceWithZIO[Redis](_.del(key).unit))
4949

5050
@Benchmark
5151
def laserdisc(): Unit = {
@@ -76,5 +76,7 @@ class LIndexBenchmarks extends BenchmarkRuntime {
7676
}
7777

7878
@Benchmark
79-
def zio(): Unit = execute(ZIO.foreachDiscard(items)(i => lIndex(key, i.toLong).returning[String]))
79+
def zio(): Unit = execute(
80+
ZIO.foreachDiscard(items)(i => ZIO.serviceWithZIO[Redis](_.lIndex(key, i.toLong).returning[String]))
81+
)
8082
}

‎benchmarks/src/main/scala/zio/redis/benchmarks/lists/LInsertBenchmarks.scala

+5-3
Original file line numberDiff line numberDiff line change
@@ -40,12 +40,12 @@ class LInsertBenchmarks extends BenchmarkRuntime {
4040
@Setup(Level.Invocation)
4141
def setup(): Unit = {
4242
items = (0 to count).toList.map(_.toString)
43-
execute(rPush(key, items.head, items.tail: _*).unit)
43+
execute(ZIO.serviceWithZIO[Redis](_.rPush(key, items.head, items.tail: _*).unit))
4444
}
4545

4646
@TearDown(Level.Invocation)
4747
def tearDown(): Unit =
48-
execute(del(key).unit)
48+
execute(ZIO.serviceWithZIO[Redis](_.del(key).unit))
4949

5050
@Benchmark
5151
def laserdisc(): Unit = {
@@ -77,5 +77,7 @@ class LInsertBenchmarks extends BenchmarkRuntime {
7777
}
7878

7979
@Benchmark
80-
def zio(): Unit = execute(ZIO.foreachDiscard(items)(i => lInsert[String, String](key, Position.Before, i, i)))
80+
def zio(): Unit = execute(
81+
ZIO.foreachDiscard(items)(i => ZIO.serviceWithZIO[Redis](_.lInsert[String, String](key, Position.Before, i, i)))
82+
)
8183
}

‎benchmarks/src/main/scala/zio/redis/benchmarks/lists/LLenBenchmarks.scala

+1-1
Original file line numberDiff line numberDiff line change
@@ -68,5 +68,5 @@ class LLenBenchmarks extends BenchmarkRuntime {
6868
}
6969

7070
@Benchmark
71-
def zio(): Unit = execute(ZIO.foreachDiscard(items)(_ => lLen[String](key)))
71+
def zio(): Unit = execute(ZIO.foreachDiscard(items)(_ => ZIO.serviceWithZIO[Redis](_.lLen[String](key))))
7272
}

‎benchmarks/src/main/scala/zio/redis/benchmarks/lists/LMoveBenchmarks.scala

+5-3
Original file line numberDiff line numberDiff line change
@@ -40,15 +40,17 @@ class LMoveBenchmarks extends BenchmarkRuntime {
4040
@Setup(Level.Trial)
4141
def setup(): Unit = {
4242
items = (0 to count).toList.map(_.toString)
43-
execute(rPush(key, items.head, items.tail: _*).unit)
43+
execute(ZIO.serviceWithZIO[Redis](_.rPush(key, items.head, items.tail: _*).unit))
4444
}
4545

4646
@TearDown(Level.Trial)
4747
def tearDown(): Unit =
48-
execute(del(key).unit)
48+
execute(ZIO.serviceWithZIO[Redis](_.del(key).unit))
4949

5050
@Benchmark
5151
def zio(): Unit = execute(
52-
ZIO.foreachDiscard(items)(_ => lMove(key, key, Side.Left, Side.Right).returning[String])
52+
ZIO.foreachDiscard(items)(_ =>
53+
ZIO.serviceWithZIO[Redis](_.lMove(key, key, Side.Left, Side.Right).returning[String])
54+
)
5355
)
5456
}

‎benchmarks/src/main/scala/zio/redis/benchmarks/lists/LPopBenchmarks.scala

+2-2
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ class LPopBenchmarks extends BenchmarkRuntime {
4040
@Setup(Level.Invocation)
4141
def setup(): Unit = {
4242
items = (0 to count).toList.map(_.toString)
43-
execute(rPush(key, items.head, items.tail: _*).unit)
43+
execute(ZIO.serviceWithZIO[Redis](_.rPush(key, items.head, items.tail: _*).unit))
4444
}
4545

4646
@Benchmark
@@ -70,5 +70,5 @@ class LPopBenchmarks extends BenchmarkRuntime {
7070
}
7171

7272
@Benchmark
73-
def zio(): Unit = execute(ZIO.foreachDiscard(items)(_ => lPop(key).returning[String]))
73+
def zio(): Unit = execute(ZIO.foreachDiscard(items)(_ => ZIO.serviceWithZIO[Redis](_.lPop(key).returning[String])))
7474
}

0 commit comments

Comments
 (0)