#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.