Commit 6ccd8a67 authored by Jakob Otto's avatar Jakob Otto

Fix string_application instantiation

parent 8a17d3c4
...@@ -70,8 +70,6 @@ typename Inspector::result_type inspect(Inspector& f, ...@@ -70,8 +70,6 @@ typename Inspector::result_type inspect(Inspector& f,
return f(meta::type_name("sa_header"), hdr.payload); return f(meta::type_name("sa_header"), hdr.payload);
} }
struct end_application {};
class string_application { class string_application {
public: public:
using header_type = string_application_header; using header_type = string_application_header;
...@@ -199,16 +197,14 @@ CAF_TEST(receive) { ...@@ -199,16 +197,14 @@ CAF_TEST(receive) {
sec::unavailable_or_would_block); sec::unavailable_or_would_block);
CAF_MESSAGE("adding both endpoint managers"); CAF_MESSAGE("adding both endpoint managers");
auto mgr1 = make_endpoint_manager(mpx, sys, policy::scribe{sockets.first}, auto mgr1 = make_endpoint_manager(mpx, sys, policy::scribe{sockets.first},
stream_string_application< extend<string_application>::with<
string_application, stream_string_application>{sys, buf});
end_application>{sys, buf});
CAF_CHECK_EQUAL(mgr1->init(), none); CAF_CHECK_EQUAL(mgr1->init(), none);
mpx->handle_updates(); mpx->handle_updates();
CAF_CHECK_EQUAL(mpx->num_socket_managers(), 2u); CAF_CHECK_EQUAL(mpx->num_socket_managers(), 2u);
auto mgr2 = make_endpoint_manager(mpx, sys, policy::scribe{sockets.second}, auto mgr2 = make_endpoint_manager(mpx, sys, policy::scribe{sockets.second},
stream_string_application< extend<string_application>::with<
string_application, stream_string_application>{sys, buf});
end_application>{sys, buf});
CAF_CHECK_EQUAL(mgr2->init(), none); CAF_CHECK_EQUAL(mgr2->init(), none);
mpx->handle_updates(); mpx->handle_updates();
CAF_CHECK_EQUAL(mpx->num_socket_managers(), 3u); CAF_CHECK_EQUAL(mpx->num_socket_managers(), 3u);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment