Akka.net -尝试测试重复的计划消息

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

public class MyActor : ReceiveActor
{
    private ICancelable _schedule;

    public MyActor()
    {
        Receive<string>(message =>
        {
            // 处理接收到的消息
        });
    }

    protected override void PreStart()
    {
        base.PreStart();

        // 定期发送计划消息
        _schedule = Context.System.Scheduler.ScheduleTellRepeatedlyCancelable(
            initialDelay: TimeSpan.FromSeconds(1),
            interval: TimeSpan.FromSeconds(1),
            receiver: Self,
            message: "Hello",
            sender: ActorRefs.NoSender
        );
    }

    protected override void PostStop()
    {
        base.PostStop();

        // 取消计划消息
        _schedule.Cancel();
    }
}

public class MyActorTests : TestKit.Xunit2.TestKit
{
    [Fact]
    public void ShouldReceiveRepeatedScheduledMessage()
    {
        var actor = Sys.ActorOf<MyActor>();

        // 创建一个TestProbe用于接收消息
        var probe = CreateTestProbe();

        // 发送一个消息给Actor
        probe.Send(actor, "Hello");

        // 断言消息是否被接收
        probe.ExpectMsg("Hello");

        // 等待一段时间，再次断言消息是否被接收
        probe.ExpectMsg("Hello", TimeSpan.FromSeconds(2));
    }
}