Skip to content

Commit a4fd3cb

Browse files
Merge pull request #51 from Swoorup/patch-1
Update RedisStreamSpec.scala
2 parents aa147e3 + 506ef4e commit a4fd3cb

1 file changed

Lines changed: 1 addition & 3 deletions

File tree

core/src/test/scala/io/chrisdavenport/rediculous/RedisStreamSpec.scala

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -69,9 +69,7 @@ class RedisStreamSpec extends CatsEffectSuite {
6969
rStream.append(messages) >>
7070
rStream
7171
.read(Set("fee"), (_ => RedisCommands.StreamOffset.From("fee", "0-0")), Duration.Zero, 1L.some)
72-
.take(4)
73-
.timeout(250.milli)
74-
.handleErrorWith(_ => fs2.Stream.empty)
72+
.take(3)
7573
.compile
7674
.toList
7775

0 commit comments

Comments
 (0)