This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository
https://gitbox.apache.org/repos/asf/incubator-pekko-persistence-dynamodb.git
The following commit(s) were added to refs/heads/main by this push:
new 9558077 fix some deprecation issues (#32)
9558077 is described below
commit 95580778930840f85b76606d5d1f27b6bb7155e1
Author: PJ Fanning <[email protected]>
AuthorDate: Fri Apr 21 19:18:10 2023 +0200
fix some deprecation issues (#32)
---
build.sbt | 1 +
.../apache/pekko/persistence/dynamodb/journal/DynamoDBHelper.scala | 2 +-
.../apache/pekko/persistence/dynamodb/journal/DynamoDBJournal.scala | 2 +-
src/main/scala/org/apache/pekko/persistence/dynamodb/package.scala | 4 ++--
4 files changed, 5 insertions(+), 4 deletions(-)
diff --git a/build.sbt b/build.sbt
index 0d85514..8d7275a 100644
--- a/build.sbt
+++ b/build.sbt
@@ -29,6 +29,7 @@ libraryDependencies ++= Seq(
"org.hdrhistogram" % "HdrHistogram" % "2.1.8" % "test",
"com.dimafeng" %% "testcontainers-scala-scalatest" %
testcontainersScalaVersion % "test")
+scalacOptions ++= Seq("-deprecation", "-feature")
Test / parallelExecution := false
// required by test-containers-scala
Test / fork := true
diff --git
a/src/main/scala/org/apache/pekko/persistence/dynamodb/journal/DynamoDBHelper.scala
b/src/main/scala/org/apache/pekko/persistence/dynamodb/journal/DynamoDBHelper.scala
index ecdaf28..53e68a6 100644
---
a/src/main/scala/org/apache/pekko/persistence/dynamodb/journal/DynamoDBHelper.scala
+++
b/src/main/scala/org/apache/pekko/persistence/dynamodb/journal/DynamoDBHelper.scala
@@ -53,7 +53,7 @@ trait DynamoDBHelper {
def name = d.desc(aws)
def sendSingle(): Future[Out] = {
- val p = Promise[Out]
+ val p = Promise[Out]()
val handler = new AsyncHandler[In, Out] {
override def onError(ex: Exception) =
diff --git
a/src/main/scala/org/apache/pekko/persistence/dynamodb/journal/DynamoDBJournal.scala
b/src/main/scala/org/apache/pekko/persistence/dynamodb/journal/DynamoDBJournal.scala
index a765895..3f9eacc 100644
---
a/src/main/scala/org/apache/pekko/persistence/dynamodb/journal/DynamoDBJournal.scala
+++
b/src/main/scala/org/apache/pekko/persistence/dynamodb/journal/DynamoDBJournal.scala
@@ -152,7 +152,7 @@ class DynamoDBJournal(config: Config)
for {
lowest <- lowF
highest <- highF
- val upTo = Math.min(toSequenceNr, highest)
+ upTo = Math.min(toSequenceNr, highest)
_ <- if (upTo + 1 > lowest) setLS(persistenceId, to = upTo + 1) else
Future.successful(Done)
_ <- if (lowest <= upTo) deleteMessages(persistenceId, lowest, upTo)
else Future.successful(Done)
} yield {
diff --git a/src/main/scala/org/apache/pekko/persistence/dynamodb/package.scala
b/src/main/scala/org/apache/pekko/persistence/dynamodb/package.scala
index 58e6daf..6468b1a 100644
--- a/src/main/scala/org/apache/pekko/persistence/dynamodb/package.scala
+++ b/src/main/scala/org/apache/pekko/persistence/dynamodb/package.scala
@@ -41,13 +41,13 @@ package object dynamodb {
def B(value: Array[Byte]): AttributeValue = new
AttributeValue().withB(ByteBuffer.wrap(value))
def lift[T](f: Future[T]): Future[Try[T]] = {
- val p = Promise[Try[T]]
+ val p = Promise[Try[T]]()
f.onComplete(p.success)(ExecutionContexts.sameThreadExecutionContext)
p.future
}
def liftUnit(f: Future[Any]): Future[Try[Unit]] = {
- val p = Promise[Try[Unit]]
+ val p = Promise[Try[Unit]]()
f.onComplete {
case Success(_) => p.success(Success(()))
case f @ Failure(_) => p.success(f.asInstanceOf[Failure[Unit]])
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
