#include <chrono>
#include <iostream>
#include <string>
#include <thread>

#include "librf/librf.h"

using namespace librf;
using namespace std::chrono;

void test_memory_leak_event_wait_for()
{
	go[]()->future_t<void>
	{
		event_t e;
		for (;;)
		{
			bool val = co_await e.wait_for(1ms);
			(void)val;
			assert(val == false);
			co_await yield();
		}
	};

	for (;;)
	{
		auto have = this_scheduler()->run_one_batch();
		if (!have) {
			std::this_thread::sleep_for(1ms);
		}
	}
}

void test_memory_leak_event_wait_all_for()
{
	go[]()->future_t<void>
	{
		event_t e[4];
		for (;;)
		{
			bool val = co_await event_t::wait_all_for(1ms, e);
			(void)val;
			assert(val == false);
			co_await yield();
		}
	};

	for (;;)
	{
		auto have = this_scheduler()->run_one_batch();
		if (!have) {
			std::this_thread::sleep_for(1ms);
		}
	}
}

#if LIBRF_TUTORIAL_STAND_ALONE
int main()
{
	//test_memory_leak_event_wait_for();
	test_memory_leak_event_wait_all_for();

	return 0;
}
#endif