scala3: fix some doc samples that didn't compile (#31016)

This commit is contained in:
Arnout Engelen 2022-01-25 15:37:33 +01:00 committed by GitHub
parent f8a47eae3e
commit 609a7c5f8d
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
5 changed files with 86 additions and 8 deletions

View file

@ -23,6 +23,9 @@ public class LambdaPersistenceDocTest {
public String persistenceId();
// #persistence-id
}
public interface PersistenceActorRecoveryMethods {
// #recovery-status
public boolean recoveryRunning();

View file

@ -77,9 +77,9 @@ class SharedMutableStateDocSpec {
// use context.ask instead, turns the completion
// into a message sent to self
context.ask(otherActor, Query(_)) {
case Success(result: String) => UpdateState(result)
case Failure(ex) => throw ex
context.ask[Query, String](otherActor, Query(_)) {
case Success(result) => UpdateState(result)
case Failure(ex) => throw ex
}
this

View file

@ -36,11 +36,14 @@ object PersistenceQueryDocSpec {
//#my-read-journal
class MyReadJournalProvider(system: ExtendedActorSystem, config: Config) extends ReadJournalProvider {
override val scaladslReadJournal: MyScaladslReadJournal =
private val readJournal: MyScaladslReadJournal =
new MyScaladslReadJournal(system, config)
override val javadslReadJournal: MyJavadslReadJournal =
new MyJavadslReadJournal(scaladslReadJournal)
override def scaladslReadJournal(): MyScaladslReadJournal =
readJournal
override def javadslReadJournal(): MyJavadslReadJournal =
new MyJavadslReadJournal(readJournal)
}
class MyScaladslReadJournal(system: ExtendedActorSystem, config: Config)

View file

@ -5,9 +5,9 @@
package akka.persistence.japi.journal
import com.typesafe.config.Config
import akka.persistence.CapabilityFlag
import akka.persistence.journal.JournalSpec
import org.scalatest.{ Args, ConfigMap, Filter, Status, Suite, TestData }
/**
* JAVA API
@ -25,4 +25,40 @@ class JavaJournalSpec(config: Config) extends JournalSpec(config) {
override protected def supportsRejectingNonSerializableObjects: CapabilityFlag = CapabilityFlag.on()
override protected def supportsSerialization: CapabilityFlag = CapabilityFlag.on()
override def runTests(testName: Option[String], args: Args): Status =
super.runTests(testName, args)
override def runTest(testName: String, args: Args): Status =
super.runTest(testName, args)
override def run(testName: Option[String], args: Args): Status =
super.run(testName, args)
override def testDataFor(testName: String, theConfigMap: ConfigMap): TestData =
super.testDataFor(testName, theConfigMap)
override def testNames: Set[String] =
super.testNames
override def tags: Map[String, Set[String]] =
super.tags
override def rerunner: Option[String] =
super.rerunner
override def expectedTestCount(filter: Filter): Int =
super.expectedTestCount(filter)
override def suiteId: String =
super.suiteId
override def suiteName: String =
super.suiteName
override def runNestedSuites(args: Args): Status =
super.runNestedSuites(args)
override def nestedSuites: IndexedSeq[Suite] =
super.nestedSuites
}

View file

@ -5,9 +5,9 @@
package akka.persistence.japi.snapshot
import com.typesafe.config.Config
import akka.persistence.CapabilityFlag
import akka.persistence.snapshot.SnapshotStoreSpec
import org.scalatest.{ Args, ConfigMap, Filter, Status, Suite, TestData }
/**
* JAVA API
@ -22,4 +22,40 @@ import akka.persistence.snapshot.SnapshotStoreSpec
*/
class JavaSnapshotStoreSpec(config: Config) extends SnapshotStoreSpec(config) {
override protected def supportsSerialization: CapabilityFlag = CapabilityFlag.on()
override def runTests(testName: Option[String], args: Args): Status =
super.runTests(testName, args)
override def runTest(testName: String, args: Args): Status =
super.runTest(testName, args)
override def run(testName: Option[String], args: Args): Status =
super.run(testName, args)
override def testDataFor(testName: String, theConfigMap: ConfigMap): TestData =
super.testDataFor(testName, theConfigMap)
override def testNames: Set[String] =
super.testNames
override def tags: Map[String, Set[String]] =
super.tags
override def rerunner: Option[String] =
super.rerunner
override def expectedTestCount(filter: Filter): Int =
super.expectedTestCount(filter)
override def suiteId: String =
super.suiteId
override def suiteName: String =
super.suiteName
override def runNestedSuites(args: Args): Status =
super.runNestedSuites(args)
override def nestedSuites: IndexedSeq[Suite] =
super.nestedSuites
}