From b8ceab84acdbc80a3f1babb4075070e53d5cc029 Mon Sep 17 00:00:00 2001
From: Meta Vens <rwvens@hotmail.com>
Date: Tue, 29 Sep 2026 16:54:40 +0200
Subject: [PATCH] Drive the escaped-observer probe through a database write

A direct cache write is not a database change on this base, so the database
observer could not show it. PutAsync is, and the observer after the thrower must
see it.

Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com>
---
 .../CultCachePublicationIsolationTests.cs                       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/tests/GameCult.Networking.Tests/CultCachePublicationIsolationTests.cs b/tests/GameCult.Networking.Tests/CultCachePublicationIsolationTests.cs
index 33d1100d..8b6106ec 100644
--- a/tests/GameCult.Networking.Tests/CultCachePublicationIsolationTests.cs
+++ b/tests/GameCult.Networking.Tests/CultCachePublicationIsolationTests.cs
@@ -77,7 +77,7 @@ namespace GameCult.Networking.Tests
                 var seen = new ConcurrentQueue<string?>();
                 using var watch = database.Watch<NetworkSchemaNote>().Subscribe(change => seen.Enqueue(change.Document?.Text));
                 var boom = new CultRecordKey("pub:boom");
-                var escaped = Assert.ThrowsAsync<InvalidOperationException>(() => cache.UpsertAsync(Note("boom"), new CultRecordHandle<NetworkSchemaNote>(boom)));
+                var escaped = Assert.ThrowsAsync<InvalidOperationException>(() => database.PutAsync(boom, Note("boom")));
 
                 ObservableSystem.RegisterUnhandledExceptionHandler(previous);
                 var after = new CultRecordKey("pub:after");