We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 91391be commit fe12036Copy full SHA for fe12036
modules/redis/src/main/scala/zio/redis/internal/SingleNodeRunner.scala
@@ -33,7 +33,7 @@ private[redis] trait SingleNodeRunner {
33
*/
34
private[internal] final val run: IO[RedisError, AnyVal] =
35
ZIO.logTrace(s"$this sender and reader has been started") *>
36
- (send.repeat(Schedule.forever) race receive
+ (send.either.repeat(Schedule.forever) race receive
37
.tapError(e => ZIO.logWarning(s"Reconnecting due to error: $e") *> onError(e))
38
.retryWhile(True))
39
.tapError(e => ZIO.logError(s"Executor exiting: $e"))
0 commit comments