From 9802644db53e17bf8242a9cbce9645f66ba32bfa Mon Sep 17 00:00:00 2001 From: Benjamin Maurer Date: Wed, 11 Sep 2024 15:20:33 +0200 Subject: [PATCH] Reflect changes to StorageExtension in README. --- README.md | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/README.md b/README.md index b18ebc7..91fb472 100644 --- a/README.md +++ b/README.md @@ -69,19 +69,21 @@ It is possible to manually clear the journal an snapshot storage, for example: ```scala import akka.actor.ActorSystem -import akka.persistence.inmemory.extension.{ InMemoryJournalStorage, InMemorySnapshotStorage, StorageExtension } +import akka.persistence.inmemory.extension.{ InMemoryJournalStorage, InMemorySnapshotStorage, StorageExtensionProvider } import akka.testkit.TestProbe import org.scalatest.{ BeforeAndAfterEach, Suite } trait InMemoryCleanup extends BeforeAndAfterEach { _: Suite => + def config: Config implicit def system: ActorSystem override protected def beforeEach(): Unit = { val tp = TestProbe() - tp.send(StorageExtension(system).journalStorage, InMemoryJournalStorage.ClearJournal) + val extension = StorageExtensionProvider(system) + tp.send(extension.journalStorage(config), InMemoryJournalStorage.ClearJournal) tp.expectMsg(akka.actor.Status.Success("")) - tp.send(StorageExtension(system).snapshotStorage, InMemorySnapshotStorage.ClearSnapshots) + tp.send(extension.snapshotStorage(config), InMemorySnapshotStorage.ClearSnapshots) tp.expectMsg(akka.actor.Status.Success("")) super.beforeEach() }