Skip to content

Commit

Permalink
Merge c6e4e8c into adb2b9c
Browse files Browse the repository at this point in the history
  • Loading branch information
tanacasino committed Dec 18, 2019
2 parents adb2b9c + c6e4e8c commit 4cbd909
Show file tree
Hide file tree
Showing 6 changed files with 13 additions and 15 deletions.
4 changes: 0 additions & 4 deletions .travis.yml
Original file line number Diff line number Diff line change
Expand Up @@ -26,10 +26,6 @@ env:

jobs:
include:
- name: "Test Scala 2.11"
env:
- SCALA_VERSION=2.11.12
- SCRIPT=test
- name: "Test Scala 2.12"
env:
- SCALA_VERSION=2.12.9
Expand Down
4 changes: 2 additions & 2 deletions build.sbt
Original file line number Diff line number Diff line change
Expand Up @@ -12,9 +12,9 @@ organization := "com.github.karelcemus"

scalaVersion := "2.13.1"

crossScalaVersions := Seq( "2.11.12", "2.12.10", scalaVersion.value )
crossScalaVersions := Seq( "2.12.10", scalaVersion.value )

playVersion := "2.7.3"
playVersion := "2.8.0"

connectorVersion := "1.9.1"

Expand Down
6 changes: 3 additions & 3 deletions src/main/scala/play/api/cache/redis/impl/AsyncJavaRedis.scala
Original file line number Diff line number Diff line change
Expand Up @@ -41,14 +41,14 @@ private[impl] class AsyncJavaRedis(internal: CacheAsyncApi)(implicit environment
internal.remove(key, classTagKey(key)).asJava
}

def get[T](key: String): CompletionStage[T] = getOrElse[T](key, None)

def getOptional[T](key: String): CompletionStage[Optional[T]] = {
def get[T](key: String): CompletionStage[Optional[T]] = {
async { implicit context =>
getOrElseOption[T](key, None).map(_.asJava)
}
}

override def getOptional[T](key: String): CompletionStage[Optional[T]] = get(key)

def getOrElse[T](key: String, block: Callable[T]): CompletionStage[T] =
getOrElseUpdate[T](key, (() => Future.successful(block.call()).asJava).asJava)

Expand Down
2 changes: 2 additions & 0 deletions src/test/resources/reference.conf
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,8 @@ akka {
log-dead-letters-during-shutdown = off

actor {
allow-java-serialization = on

# disables warning
warn-about-java-serializer-usage = off
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,18 +21,18 @@ class AsyncJavaRedisSpec(implicit ee: ExecutionEnv) extends Specification with R

"get and miss" in new MockedJavaRedis {
async.get[String](anyString)(anyClassTag) returns None
cache.get[String](key).asScala must beNull.await
cache.get[String](key).asScala must beEqualTo(Optional.empty).await
}

"get and hit" in new MockedJavaRedis {
async.get[String](beEq(key))(anyClassTag) returns Some(value)
async.get[String](beEq(classTagKey))(anyClassTag) returns Some(classTag)
cache.get[String](key).asScala must beEqualTo(value).await
cache.get[String](key).asScala must beEqualTo(Optional.of(value)).await
}

"get null" in new MockedJavaRedis {
async.get[String](beEq(classTagKey))(anyClassTag) returns Some("null")
cache.get[String](key).asScala must beNull.await
cache.get[String](key).asScala must beEqualTo(Optional.empty).await
there was one(async).get[String](classTagKey)
}

Expand Down Expand Up @@ -134,7 +134,7 @@ class AsyncJavaRedisSpec(implicit ee: ExecutionEnv) extends Specification with R
// hit on GET
async.get[Byte](beEq(key))(anyClassTag) returns Some(byte)
async.get[String](beEq(classTagKey))(anyClassTag) returns Some("java.lang.Byte")
cache.get[Byte](key).asScala must beEqualTo(byte).await
cache.get[Byte](key).asScala must beEqualTo(Optional.ofNullable(byte)).await
}

"get and set 'byte[]'" in new MockedJavaRedis {
Expand All @@ -148,7 +148,7 @@ class AsyncJavaRedisSpec(implicit ee: ExecutionEnv) extends Specification with R
// hit on GET
async.get[Array[Byte]](beEq(key))(anyClassTag) returns Some(bytes)
async.get[String](beEq(classTagKey))(anyClassTag) returns Some("byte[]")
cache.get[Array[Byte]](key).asScala must beEqualTo(bytes).await
cache.get[Array[Byte]](key).asScala must beEqualTo(Optional.ofNullable(bytes)).await
}

"get all" in new MockedJavaRedis {
Expand Down
2 changes: 1 addition & 1 deletion version.sbt
Original file line number Diff line number Diff line change
@@ -1 +1 @@
version in ThisBuild := "2.5.1-SNAPSHOT"
version in ThisBuild := "2.6.0-SNAPSHOT"

0 comments on commit 4cbd909

Please sign in to comment.