fasyncactor.cpp

TEST(SimpleActorTest, WhenUsingAsyncStatefulActorThenHasExpectedState)
  {
    const int MESSAGES_COUNT = 101;
    const int EXPECTED_STATE = MESSAGES_COUNT;
    auto seenMessages = 0;
    auto testState = 0;
    {
      //Create the actor (asynchronous logic/with state/no reply).
      auto stateFullActor = RStein::AsyncCpp::Actors::CreateAsyncSimpleActor<int, int>([&seenMessages, &testState](const int& message, const int& state)->Task<int>
        {
          //Process the message argument.
          seenMessages++;

          //We can use the co_await keyword in the asynchronous method.
          co_await GetCompletedTask().ConfigureAwait(false);
          
          //Update the actor state, the argument state is an old (last) actor state.
          auto newState = state + 1;
          testState = newState;
          //Return the new state.
          co_return newState;
        }, testState);

      for (int i = 0; i < MESSAGES_COUNT; i++)
      {
        stateFullActor->Tell(i);
      }
    }// The actor logic completes and the actor is destroyed. Alternatively, you can call the Complete method and wait for the actor Completion task.
    
    ASSERT_EQ(EXPECTED_STATE, testState);
  }