Skip to content

Commit

Permalink
Use rest which was still in lexical scope
Browse files Browse the repository at this point in the history
  • Loading branch information
ChristopherDavenport committed Apr 4, 2023
1 parent e92c19e commit 9767cb3
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -589,14 +589,14 @@ object RedisConnection{
keypool.take(server).attempt.use{
case Right(m) =>
val out = Chunk.seq(rest.map(_._5))
explicitPipelineRequest(m.value, out).map(c => (c, rest)).attempt.flatTap{// Currently Guarantee Chunk.size === returnSize
explicitPipelineRequest(m.value, out).attempt.flatTap{// Currently Guarantee Chunk.size === returnSize
case Left(_) => m.canBeReused.set(Reusable.DontReuse)
case _ => Applicative[F].unit
}
case l@Left(_) => l.rightCast[(Chunk[Resp], List[((Either[Throwable, Resp]) => F[Unit], Option[ByteVector], Option[(Host,Port)], Int, Resp)])].pure[F]
case l@Left(_) => l.rightCast[Chunk[Resp]].pure[F]
}.flatMap{
case Right((n, thisChunk)) =>
thisChunk.zipWithIndex.traverse_{
case Right(n) =>
rest.zipWithIndex.traverse_{
case ((toSet, key, _, retries, initialCommand), i) =>
val ref = Either.catchNonFatal(n(i))
ref match {
Expand Down

0 comments on commit 9767cb3

Please sign in to comment.