public void LoadSubscriptionUpdates(long userId)
{
    var users = usersService.GetSubscriptions(userId);
    usersServiceRequests.LogServiceCall(userId, users, users.Count);
    
    var lastUpdateTime = updatesRepository.GetLatestUpdateTime();
    var now = timeService.UtcNow;
    
    var updates = usersService.GetUpdates(users.Emails, lastUpdateTime, now);
    usersServiceRequests.LogServiceCall(users.Emails, updates.Count, lastUpdateTime.ToUnixTimeStamp());
    
    var updatesDal = _dataConverter.ToDal(users, updates, lastUpdateTime, now);
    updatesRepository.Add(userId, updatesDal);
}

[Fact("Should call GetSubscriptions")]
public void ShouldCallGetSubscriptions()
{
    // Arrange
    usersServiceMock.Setup(s => s.GetSubscriptions(74)).Returns(new Users {});
    usersServiceMock.Setup(s => s.GetUpdates(It.IsAny(), It.IsAny(), It.IsAny()).Returns(new Updates {});
    
    // Act
    usersLoader.LoadSubscriptionUpdates(74);
    
    // Assert
    usersServiceMock.Verify(s => s.GetSubscriptions(74), Times.Once());
}

[Fact("Should log GetSubscriptions call")]
public void ShouldLogCallGetSubscriptions()
{
    // Arrange
    usersServiceMock.Setup(s => s.GetSubscriptions(74)).Returns(new Users {Count = 10 });
    usersServiceMock.Setup(s => s.GetUpdates(It.IsAny(), It.IsAny(), It.IsAny()).Returns(new Updates {});
    
    // Act
    usersLoader.LoadSubscriptionUpdates(74);
    
    // Assert
    usersServiceRequestsMock.Verify(s => s.LogServiceCall(74, users, 10), Times.Once());
}

[Fact("Should call GetLatestUpdateTime")]
public void ShouldGetLatestUpdateTime()
{
    // Arrange
    usersServiceMock.Setup(s => s.GetSubscriptions(74)).Returns(new Users {Count = 10 });
    usersServiceMock.Setup(s => s.GetUpdates(It.IsAny(), It.IsAny(), It.IsAny()).Returns(new Updates {});
    
    // Act
    usersLoader.LoadSubscriptionUpdates(74);
    
    // Assert
    updatesRepositoryMock.Verify(s => s.GetLatestUpdateTime(), Times.Once());
}

[Fact("Should call GetUtcNow")]
public void ShouldGetUtcNow()
{
    // Arrange
    usersServiceMock.Setup(s => s.GetSubscriptions(74)).Returns(new Users {Count = 10 });
    usersServiceMock.Setup(s => s.GetUpdates(It.IsAny(), It.IsAny(), It.IsAny()).Returns(new Updates {});
    
    // Act
    usersLoader.LoadSubscriptionUpdates(74);
    
    // Assert
    timeServiceMock.Verify(s => s.UtcNow(), Times.Once());
}

[Fact("Should call GetUtcNow")]
public void ShouldGetUpdates()
{
    // Arrange
    usersServiceMock.Setup(s => s.GetSubscriptions(74)).Returns(new Users {Count = 10 });
    usersServiceMock.Setup(s => s.GetUpdates(It.IsAny(), It.IsAny(), It.IsAny()).Returns(new Updates {});
    
    // Act
    usersLoader.LoadSubscriptionUpdates(74);
    
    // Assert
    usersServiceMock.Verify(s => s.GetUpdates(new[] {"email1", "email2" }, lastUpdateTime, now), Times.Once());
}

[Fact("Should convert to dal")]
public void ShouldConvertToDal()
{
    // Arrange
    usersServiceMock.Setup(s => s.GetSubscriptions(74)).Returns(new Users {Count = 10 });
    usersServiceMock.Setup(s => s.GetUpdates(It.IsAny(), It.IsAny(), It.IsAny()).Returns(new Updates {});
    
    // Act
    usersLoader.LoadSubscriptionUpdates(74);
    
    // Assert
    dataConverterMock.Verify(s => s.ToDal(users, updates, lastUpdateTime, now), Times.Once());
}

[Fact("Should save to updatesRepository")]
public void ShouldSaveToupdatesRepository()
{
    // Arrange
    usersServiceMock.Setup(s => s.GetSubscriptions(74)).Returns(new Users {Count = 10 });
    usersServiceMock.Setup(s => s.GetUpdates(It.IsAny(), It.IsAny(), It.IsAny()).Returns(new Updates {});
    
    // Act
    usersLoader.LoadSubscriptionUpdates(74);
    
    // Assert
    updatesRepositoryMock.Verify(s => s.Add(userId, updatesDal), Times.Once());
}

UPS>public void LoadSubscriptionUpdates(long userId)
UPS>{
UPS>    var users = usersService.GetSubscriptions(userId);
UPS>    usersServiceRequests.LogServiceCall(userId, users, users.Count);
    
UPS>    var lastUpdateTime = updatesRepository.GetLatestUpdateTime();
UPS>    var now = timeService.UtcNow;
    
UPS>    var updates = usersService.GetUpdates(users.Emails, lastUpdateTime, now);
UPS>    usersServiceRequests.LogServiceCall(users.Emails, updates.Count, lastUpdateTime.ToUnixTimeStamp());
    
UPS>    var updatesDal = _dataConverter.ToDal(users, updates, lastUpdateTime, now);
UPS>    updatesRepository.Add(userId, updatesDal);
UPS>}
UPS>

public Updates GetSubscriptionUpdates(User user, Time now) 
// а нехрен таскать по id все подряд. 
// Время всегда тащится сверху и не надо мучить попу моками.
{
    var subscriptions = usersService.GetSubscriptions(user);
    // логирование внутри GetSubscriptions
 
    var lastUpdateTime = subscriptionService.GetLatestUpdateTime(subscriptions);
    // логирование внутри GetLatestUpdateTime
    
    
    var updates = updateService.GetUpdates(subscriptions, lastUpdateTime, now); 
    // логирование внутри GetUpdates
    
    return updates;
}

public void SetSubscriptionUpdate(Updates updates, Time now) {

  //var updatesDal = _dataConverter.ToDal(users, updates, lastUpdateTime, now);
  // мусор в строке выше должен быть унутре репозитория
    updatesRepository.Add(updates, now);
}

[Fact("Should call GetSubscriptions")]

class TaskProcessor : ITaskProcessor
{
    public void ProcessTask(Task task) // можно тестить обработку всего таска
    {
        while(!IsProcessed(task.Status)) 
        {
            task.Status = taskProcessor.ProcesTaskStatus(task);
            // чего то ещё делаем
        }
    }
}

class TaskStatusProcessor : ITaskStatusProcessor
{
    public void ProcesTaskStatus(Task task) // можно тестить обработку отдельного статуса
    {
        switch(task.Status)
        {
            // процессим конкретные статусы
        }
    }
}

Можно менять внутренние модули, из которых состоит фича без возни с тестами.
Заодно тестируется БД.
Заодно тестируется многопоточное поведение.
Заодно тестируются временные аспекты. К примеру, операции по таймауту.
Заодно тестируется конфиг.
Не нужно делать угадайки о том, какие данные будут приходить в модули.

var lastUpdateTime = updatesRepository.GetLatestUpdateTime();
var now = timeService.UtcNow;
var updates = usersService.GetUpdates(users.Emails, lastUpdateTime, now);