Skip to content

Commit 13c19ac

Browse files
committed
Changes to fix deprecations for Scala 2.13-M4
1 parent 94e503a commit 13c19ac

File tree

5 files changed

+5
-5
lines changed

5 files changed

+5
-5
lines changed

build.sbt

+1-1
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ lazy val redisClient = (project in file(".")).settings(coreSettings : _*)
44

55
lazy val commonSettings: Seq[Setting[_]] = Seq(
66
organization := "net.debasishg",
7-
version := "3.7",
7+
version := "3.8",
88
scalaVersion := "2.12.6",
99
crossScalaVersions := Seq("2.12.6", "2.11.12", "2.10.7", "2.13.0-M4"),
1010

src/main/scala/com/redis/IO.scala

+1-1
Original file line numberDiff line numberDiff line change
@@ -93,7 +93,7 @@ trait IO extends Log {
9393
} else {
9494
if (found != Nil) {
9595
delimiter = crlf
96-
build ++= found.reverseMap(_.toByte)
96+
build ++= found.reverseIterator.map(_.toByte).toList
9797
found = Nil
9898
}
9999
build += next.toByte

src/main/scala/com/redis/cluster/HashRing.scala

+1-1
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ case class HashRing[T](nodes: List[T], replicas: Int) {
7676
def isEmpty: Boolean = ring.isEmpty
7777

7878
private def nodeHashFor(node: T, replica: Int): Long = {
79-
calculateChecksum((node + ":" + replica).getBytes("UTF-8"))
79+
calculateChecksum((node + ":" + replica).getBytes("UTF-8").toIndexedSeq)
8080
}
8181

8282
}

src/main/scala/com/redis/cluster/RedisCluster.scala

+1-1
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,7 @@ abstract class RedisCluster(hosts: ClusterNode*) extends RedisCommand {
8181
// get node for the key
8282
def nodeForKey(key: Any)(implicit format: Format): IdentifiableRedisClientPool = {
8383
val bKey = format(key)
84-
hr.getNode(keyTag.flatMap(_.tag(bKey)).getOrElse(bKey))
84+
hr.getNode(keyTag.flatMap(_.tag(bKey.toIndexedSeq)).getOrElse(bKey.toIndexedSeq))
8585
}
8686

8787
def processForKey[T](key: Any)(body: RedisCommand => T)(implicit format: Format): T = {

src/main/scala/com/redis/cluster/RedisShards.scala

+1-1
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ abstract class RedisShards(val hosts: List[ClusterNode]) extends RedisCommand {
2525
// get node for the key
2626
def nodeForKey(key: Any)(implicit format: Format): RedisClientPool = {
2727
val bKey = format(key)
28-
val selectedNode = hr.getNode(keyTag.flatMap(_.tag(bKey)).getOrElse(bKey))
28+
val selectedNode = hr.getNode(keyTag.flatMap(_.tag(bKey.toIndexedSeq)).getOrElse(bKey.toIndexedSeq))
2929
clients(selectedNode)
3030
}
3131

0 commit comments

Comments
 (0)