如何在Akka.net中用TestKit测试DistributedPubSub？

using Akka.Actor;
using Akka.TestKit;
using Akka.TestKit.Xunit2;
using Xunit;

public class DistributedPubSubTests : TestKit
{
    private readonly ActorSystem _system;

    public DistributedPubSubTests()
    {
        _system = ActorSystem.Create("MyActorSystem");
    }

    // 测试方法将在这里
}

[Fact]
public void TestDistributedPubSub()
{
    var testActor = _system.ActorOf(Props.Create(() => new TestActor()), "testActor");
    var distributedPubSub = DistributedPubSub.Get(_system);

    // 执行测试逻辑
}

[Fact]
public void TestDistributedPubSub()
{
    var testActor = _system.ActorOf(Props.Create(() => new TestActor()), "testActor");
    var distributedPubSub = DistributedPubSub.Get(_system);

    // 发布订阅消息
    distributedPubSub.Mediator.Tell(new DistributedPubSubMediator.Publish("topic", "message"));

    // 预期接收到消息
    ExpectMsg<DistributedPubSubMediator.PublishAck>();

    // 执行其他测试逻辑
}

public class TestActor : ReceiveActor
{
    public TestActor()
    {
        Receive<string>(message =>
        {
            // 处理接收到的消息
            Sender.Tell("response");
        });
    }
}