Remove warnings in persistence typed module (#26748)

This commit is contained in:
Christopher Batey 2019-04-16 16:12:28 +01:00 committed by GitHub
parent 3abc3583b6
commit d17d303110
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
5 changed files with 10 additions and 8 deletions

View file

@ -33,14 +33,14 @@ class EventSourcedSequenceNumberSpec
private def behavior(pid: PersistenceId, probe: ActorRef[String]): Behavior[String] =
Behaviors.setup(ctx =>
EventSourcedBehavior[String, String, String](pid, "", { (_, command) =>
probe ! (EventSourcedBehavior.lastSequenceNumber(ctx) + " onCommand")
Effect.persist(command).thenRun(_ => probe ! (EventSourcedBehavior.lastSequenceNumber(ctx) + " thenRun"))
probe ! s"${EventSourcedBehavior.lastSequenceNumber(ctx)} onCommand"
Effect.persist(command).thenRun(_ => probe ! s"${EventSourcedBehavior.lastSequenceNumber(ctx)} thenRun")
}, { (state, evt) =>
probe ! (EventSourcedBehavior.lastSequenceNumber(ctx) + " eventHandler")
probe ! s"${EventSourcedBehavior.lastSequenceNumber(ctx)} eventHandler"
state + evt
}).receiveSignal {
case (_, RecoveryCompleted) =>
probe ! (EventSourcedBehavior.lastSequenceNumber(ctx) + " onRecoveryComplete")
probe ! s"${EventSourcedBehavior.lastSequenceNumber(ctx)} onRecoveryComplete"
})
"The sequence number" must {

View file

@ -17,8 +17,6 @@ import akka.actor.typed.scaladsl.Behaviors
import akka.persistence.typed.PersistenceId
import akka.persistence.typed.RecoveryCompleted
import akka.persistence.typed.scaladsl.EventSourcedBehavior.CommandHandler
import akka.testkit.EventFilter
import akka.testkit.TestEvent.Mute
import com.typesafe.config.ConfigFactory
import org.scalatest.WordSpecLike

View file

@ -11,9 +11,12 @@ import akka.actor.typed.scaladsl.Behaviors
import akka.actor.typed.scaladsl.TimerScheduler
import akka.persistence.typed.PersistenceId
import akka.persistence.typed.RecoveryCompleted
import com.github.ghik.silencer.silent
import scala.concurrent.Future
// unused names in pattern match can be useful in the docs
@silent
object PersistentActorCompileOnlyTest {
import akka.persistence.typed.scaladsl.EventSourcedBehavior._

View file

@ -5,7 +5,6 @@
package docs.akka.persistence.typed
import scala.concurrent.duration._
import akka.actor.typed.Behavior
import akka.actor.typed.SupervisorStrategy
import akka.actor.typed.scaladsl.Behaviors
@ -15,7 +14,10 @@ import akka.persistence.typed.PersistenceId
import akka.persistence.typed.RecoveryCompleted
import akka.persistence.typed.SnapshotFailed
import akka.persistence.typed.scaladsl.EventSourcedBehavior
import com.github.ghik.silencer.silent
// unused variables in pattern match are useful in the docs
@silent
object BasicPersistentBehaviorCompileOnly {
import akka.persistence.typed.scaladsl.RetentionCriteria

View file

@ -31,7 +31,6 @@ object AkkaDisciplinePlugin extends AutoPlugin with ScalafixSupport {
"akka-bench-jmh-typed",
"akka-multi-node-testkit",
"akka-persistence-tck",
"akka-persistence-typed",
"akka-remote",
"akka-stream-tests",
"akka-stream-tests-tck",