From f1cab068e585eec0c3bc9f9bd612307b0ac09f6f Mon Sep 17 00:00:00 2001 From: Chris Philips Date: Sun, 14 Jan 2024 12:04:24 -0800 Subject: [PATCH] fix: this Append is void, not async --- src/EntityDb.Abstractions/Streams/IMultipleStreamRepository.cs | 2 +- src/EntityDb.Common/Streams/MultipleStreamRepository.cs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/EntityDb.Abstractions/Streams/IMultipleStreamRepository.cs b/src/EntityDb.Abstractions/Streams/IMultipleStreamRepository.cs index 3efb7a92..1e6da3e1 100644 --- a/src/EntityDb.Abstractions/Streams/IMultipleStreamRepository.cs +++ b/src/EntityDb.Abstractions/Streams/IMultipleStreamRepository.cs @@ -26,7 +26,7 @@ public interface IMultipleStreamRepository : IDisposableResource /// A task. Task LoadOrCreate(Key streamKey, CancellationToken cancellationToken = default); - void Append(Key streamKey, object delta, CancellationToken cancellationToken = default); + void Append(Key streamKey, object delta); /// /// Stages a single delta with a given state key and message key. diff --git a/src/EntityDb.Common/Streams/MultipleStreamRepository.cs b/src/EntityDb.Common/Streams/MultipleStreamRepository.cs index 6afd71bc..1be0f0f3 100644 --- a/src/EntityDb.Common/Streams/MultipleStreamRepository.cs +++ b/src/EntityDb.Common/Streams/MultipleStreamRepository.cs @@ -89,7 +89,7 @@ public void Create(Key streamKey) }); } - public void Append(Key streamKey, object delta, CancellationToken cancellationToken = default) + public void Append(Key streamKey, object delta) { if (!_knownStreams.TryGetValue(streamKey, out var stream)) {