Merge pull request #365 from arturaz/issue/364

Fix: hmGet throws an exception if one of the keys doesn't have a value
profunktor · Sep 15, 2020 · dfd5d76 · dfd5d76
2 parents c982ee5 + 01d55ef
commit dfd5d76
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/modules/effects/src/main/scala/dev/profunktor/redis4cats/redis.scala b/modules/effects/src/main/scala/dev/profunktor/redis4cats/redis.scala
@@ -699,7 +699,7 @@ private[redis4cats] class BaseRedis[F[_]: Concurrent: ContextShift, K, V](
     async
       .flatMap(c => F.delay(c.hmget(key, fields: _*)))
       .futureLift
-      .map(_.asScala.toList.map(kv => kv.getKey -> kv.getValue).toMap)
+      .map(_.asScala.toList.collect { case kv if kv.hasValue => kv.getKey -> kv.getValue }.toMap)
 
   override def hKeys(key: K): F[List[K]] =
     async