diff --git a/src/contrib/cluster/Akka.Cluster.Sharding.Tests.MultiNode/AsyncWriteProxyEx.cs b/src/contrib/cluster/Akka.Cluster.Sharding.Tests.MultiNode/AsyncWriteProxyEx.cs
index 040f9701137..b5949b2a542 100644
--- a/src/contrib/cluster/Akka.Cluster.Sharding.Tests.MultiNode/AsyncWriteProxyEx.cs
+++ b/src/contrib/cluster/Akka.Cluster.Sharding.Tests.MultiNode/AsyncWriteProxyEx.cs
@@ -162,18 +162,19 @@ protected internal override bool AroundReceive(Receive receive, object message)
/// TBD
///
/// TBD
+ /// The to stop async operation
///
/// This exception is thrown when the store has not been initialized.
///
/// TBD
- protected override Task> WriteMessagesAsync(IEnumerable messages)
+ protected override Task> WriteMessagesAsync(IEnumerable messages, CancellationToken cancellationToken = default)
{
var trueMsgs = messages.ToArray();
if (_store == null)
return StoreNotInitialized>();
- return _store.Ask