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/pekko-persistence-r2dbc.git
The following commit(s) were added to refs/heads/main by this push:
new dd3194f durable-state: empty tag test (#346)
dd3194f is described below
commit dd3194f5e29036f4dd3736cb8d3ff99bbcaad4e9
Author: PJ Fanning <[email protected]>
AuthorDate: Wed Apr 8 14:42:21 2026 +0200
durable-state: empty tag test (#346)
---
.../pekko/persistence/r2dbc/state/DurableStateStoreSpec.scala | 10 ++++++++++
1 file changed, 10 insertions(+)
diff --git
a/core/src/test/scala/org/apache/pekko/persistence/r2dbc/state/DurableStateStoreSpec.scala
b/core/src/test/scala/org/apache/pekko/persistence/r2dbc/state/DurableStateStoreSpec.scala
index 98d63a1..4d12e1b 100644
---
a/core/src/test/scala/org/apache/pekko/persistence/r2dbc/state/DurableStateStoreSpec.scala
+++
b/core/src/test/scala/org/apache/pekko/persistence/r2dbc/state/DurableStateStoreSpec.scala
@@ -39,6 +39,7 @@ class DurableStateStoreSpec
.durableStateStoreFor[R2dbcDurableStateStore[String]](R2dbcDurableStateStore.Identifier)
private val unusedTag = "n/a"
+ private val emptyTag = ""
"The R2DBC durable state store" should {
"save and retrieve a value" in {
@@ -50,6 +51,15 @@ class DurableStateStoreSpec
store.getObject(persistenceId).futureValue should
be(GetObjectResult(Some(value), 1L))
}
+ "save and retrieve a value with empty tag" in {
+ val entityType = nextEntityType()
+ val persistenceId = PersistenceId(entityType,
"my-persistenceId-empty-tag").id
+ val value = "Genuinely Collaborative"
+
+ store.upsertObject(persistenceId, 1L, value, emptyTag).futureValue
+ store.getObject(persistenceId).futureValue should
be(GetObjectResult(Some(value), 1L))
+ }
+
"produce None when fetching a non-existing key" in {
val entityType = nextEntityType()
val key = PersistenceId(entityType, "nonexistent-id").id
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
