#include <chrono>
#include <string>
#include <gtest/gtest.h>
#include <gmock/gmock.h>
#include <dataflow_lite/dataflow/sink.h>
#include <dataflow_lite/dataflow/source.h>
#include <dataflow_lite/dataflow/observed_queue.h>
Go to the source code of this file.
Functions | |
TEST (observed_queue_test, Sanity) | |
TEST (observed_queue_test, enqueue_dequeue_test) | |
TEST (observed_queue_test, blocking_enqueue_dequeue_test) | |
TEST (observed_queue_test, synchronized_enqueue_dequeue_test) | |
TEST (observed_queue_test, enqueue_blocked_dequeue_test) | |
void | test_enqueue_dequeue (IObservedQueue< std::string > &observed_queue) |
TEST | ( | observed_queue_test | , |
Sanity | |||
) |
Definition at line 42 of file observed_queue_test.cpp.
TEST | ( | observed_queue_test | , |
enqueue_dequeue_test | |||
) |
Definition at line 46 of file observed_queue_test.cpp.
TEST | ( | observed_queue_test | , |
blocking_enqueue_dequeue_test | |||
) |
Definition at line 51 of file observed_queue_test.cpp.
TEST | ( | observed_queue_test | , |
synchronized_enqueue_dequeue_test | |||
) |
Definition at line 56 of file observed_queue_test.cpp.
TEST | ( | observed_queue_test | , |
enqueue_blocked_dequeue_test | |||
) |
Definition at line 61 of file observed_queue_test.cpp.
void test_enqueue_dequeue | ( | IObservedQueue< std::string > & | observed_queue | ) |
Definition at line 28 of file observed_queue_test.cpp.