#include "test.h"
#include <carla/ThreadGroup.h>
#include <carla/streaming/Client.h>
#include <carla/streaming/Server.h>
#include <carla/streaming/detail/Dispatcher.h>
#include <carla/streaming/detail/tcp/Client.h>
#include <carla/streaming/detail/tcp/Server.h>
#include <carla/streaming/low_level/Client.h>
#include <carla/streaming/low_level/Server.h>
#include <atomic>
类 | |
struct | DoneGuard |
class | io_context_running |
函数 | |
TEST (streaming, low_level_sending_strings) | |
TEST (streaming, low_level_tcp_small_message) | |
TEST (streaming, low_level_unsubscribing) | |
TEST (streaming, multi_stream) | |
TEST (streaming, stream_outlives_server) | |
TEST | ( | streaming | , |
low_level_sending_strings | ) |
TEST | ( | streaming | , |
low_level_tcp_small_message | ) |
在文件 test_streaming.cpp 第 134 行定义.
引用了 carla::BufferView::CreateFrom(), carla::ThreadGroup::CreateThreads(), carla::streaming::detail::tcp::Server::GetLocalEndpoint(), carla::streaming::detail::tcp::Server::Listen(), carla::streaming::detail::Dispatcher::MakeStream(), carla::streaming::detail::tcp::Server::SetTimeout() , 以及 TESTING_PORT.
TEST | ( | streaming | , |
low_level_unsubscribing | ) |
在文件 test_streaming.cpp 第 85 行定义.
引用了 carla::BufferView::CreateFrom(), carla::streaming::low_level::Server< T >::MakeStream(), io_context_running::service, carla::streaming::low_level::Server< T >::SetTimeout(), carla::streaming::low_level::Client< T >::Subscribe(), TESTING_PORT , 以及 carla::streaming::low_level::Client< T >::UnSubscribe().
TEST | ( | streaming | , |
multi_stream | ) |
在文件 test_streaming.cpp 第 239 行定义.
引用了 carla::streaming::Server::AsyncRun(), carla::BufferView::CreateFrom(), carla::streaming::Server::MakeStream() , 以及 TESTING_PORT.
TEST | ( | streaming | , |
stream_outlives_server | ) |