aboutsummaryrefslogblamecommitdiffstats
path: root/library/cpp/messagebus/rain_check/test/helper/misc.cpp
blob: e0a88a8ab9f5eda42d436a2ef8f586cefe1f9ba0 (plain) (tree)
1
2
3
4
5
6
7
8
                 


                                
                                    
                                          





                                                            
                                                 
                                          





                                                              
                                                
                   
#include "misc.h"

#include <util/system/yassert.h>

using namespace NRainCheck;

void TSpawnNopTasksCoroTask::Run() {
    Y_VERIFY(Count <= Completion.size()); 
    for (unsigned i = 0; i < Count; ++i) {
        SpawnSubtask<TNopCoroTask>(Env, &Completion[i], "");
    }

    WaitForSubtasks();
}

TContinueFunc TSpawnNopTasksSimpleTask::Start() {
    Y_VERIFY(Count <= Completion.size()); 
    for (unsigned i = 0; i < Count; ++i) {
        SpawnSubtask<TNopSimpleTask>(Env, &Completion[i], "");
    }

    return &TSpawnNopTasksSimpleTask::Join;
}

TContinueFunc TSpawnNopTasksSimpleTask::Join() {
    return nullptr;
}