Inheritance diagram for StreamProcessorTest:

Collaboration diagram for StreamProcessorTest:

Protected Member Functions
void	SetUp () override

void	TearDown () override

bool	wait_for_flag (const std::atomic< bool > &flag, std::chrono::milliseconds timeout=std::chrono::milliseconds(500))

bool	wait_for_count (const std::atomic< int > &counter, int target, std::chrono::milliseconds timeout=std::chrono::milliseconds(500))

Protected Attributes
std::shared_ptr< async_stub_backend >	backend_

std::unique_ptr< stream_processor >	processor_

Detailed Description

Definition at line 1158 of file test_async_operations.cpp.

Member Function Documentation

◆ SetUp()

void StreamProcessorTest::SetUp ( )

inlineoverrideprotected

Definition at line 1160 of file test_async_operations.cpp.

                          {
        backend_ = std::make_shared<async_stub_backend>();
        processor_ = std::make_unique<stream_processor>(backend_);
    }

References backend_, and processor_.

◆ TearDown()

void StreamProcessorTest::TearDown ( )

inlineoverrideprotected

Definition at line 1165 of file test_async_operations.cpp.

                             {
        processor_.reset();
    }

References processor_.

◆ wait_for_count()

bool StreamProcessorTest::wait_for_count	(	const std::atomic< int > &	counter,
		int	target,
		std::chrono::milliseconds	timeout = std::chrono::milliseconds(500) )

inlineprotected

Definition at line 1181 of file test_async_operations.cpp.

    {
        auto deadline = std::chrono::steady_clock::now() + timeout;
        while (counter.load() < target && std::chrono::steady_clock::now() < deadline) {
            std::this_thread::sleep_for(std::chrono::milliseconds(5));
        }
        return counter.load() >= target;
    }

◆ wait_for_flag()

bool StreamProcessorTest::wait_for_flag	(	const std::atomic< bool > &	flag,
		std::chrono::milliseconds	timeout = std::chrono::milliseconds(500) )

inlineprotected

Definition at line 1170 of file test_async_operations.cpp.

    {
        auto deadline = std::chrono::steady_clock::now() + timeout;
        while (!flag.load() && std::chrono::steady_clock::now() < deadline) {
            std::this_thread::sleep_for(std::chrono::milliseconds(5));
        }
        return flag.load();
    }

Member Data Documentation

◆ backend_

std::shared_ptr<async_stub_backend> StreamProcessorTest::backend_

protected

Definition at line 1191 of file test_async_operations.cpp.

Referenced by SetUp().

◆ processor_

std::unique_ptr<stream_processor> StreamProcessorTest::processor_

protected

Definition at line 1192 of file test_async_operations.cpp.

Referenced by SetUp(), and TearDown().

The documentation for this class was generated from the following file:

tests/async/test_async_operations.cpp

Protected Member Functions

Protected Attributes