diff --git a/core/src/main/scala/com/github/gvolpe/fs2redis/algebra/strings.scala b/core/src/main/scala/com/github/gvolpe/fs2redis/algebra/strings.scala index bb56a782..c72479e3 100644 --- a/core/src/main/scala/com/github/gvolpe/fs2redis/algebra/strings.scala +++ b/core/src/main/scala/com/github/gvolpe/fs2redis/algebra/strings.scala @@ -25,7 +25,7 @@ trait StringCommands[F[_], K, V] with Decrement[F, K, V] with Increment[F, K, V] with Bits[F, K, V] { - def del(key: K): F[Unit] + def del(key: K*): F[Unit] def expire(k: K, seconds: FiniteDuration): F[Unit] } diff --git a/core/src/main/scala/com/github/gvolpe/fs2redis/interpreter/Fs2Redis.scala b/core/src/main/scala/com/github/gvolpe/fs2redis/interpreter/Fs2Redis.scala index 76caf3bc..c1905985 100644 --- a/core/src/main/scala/com/github/gvolpe/fs2redis/interpreter/Fs2Redis.scala +++ b/core/src/main/scala/com/github/gvolpe/fs2redis/interpreter/Fs2Redis.scala @@ -80,9 +80,9 @@ private[fs2redis] class Fs2Redis[F[_], K, V](val client: StatefulRedisConnection import scala.collection.JavaConverters._ - override def del(key: K): F[Unit] = + override def del(key: K*): F[Unit] = JRFuture { - F.delay(client.async().del(key)) + F.delay(client.async().del(key: _*)) }.void override def expire(key: K, expiresIn: FiniteDuration): F[Unit] =