Commit 61efab6c authored by Dominik Charousset's avatar Dominik Charousset

Port caf_bb to latest CAF master API

parent 33d43236
...@@ -91,7 +91,7 @@ CAF_TEST(stream_to_sink) { ...@@ -91,7 +91,7 @@ CAF_TEST(stream_to_sink) {
auto src = sys.spawn(bb::container_source<container_type, actor>, auto src = sys.spawn(bb::container_source<container_type, actor>,
test_container, sink); test_container, sink);
auto mon = sys.spawn(container_monitor); auto mon = sys.spawn(container_monitor);
self->send(mon, join_atom::value, src); self->send(mon, join_atom_v, src);
run(); run();
CAF_CHECK_EQUAL(deref<container_sink_actor>(sink).state.con, test_container); CAF_CHECK_EQUAL(deref<container_sink_actor>(sink).state.con, test_container);
} }
...@@ -106,7 +106,7 @@ CAF_TEST(stream_to_sinks) { ...@@ -106,7 +106,7 @@ CAF_TEST(stream_to_sinks) {
.spawn(bb::container_source<container_type, actor, actor, actor>, .spawn(bb::container_source<container_type, actor, actor, actor>,
test_container, snk1, snk2, snk3); test_container, snk1, snk2, snk3);
auto mon = sys.spawn(container_monitor); auto mon = sys.spawn(container_monitor);
self->send(mon, join_atom::value, src); self->send(mon, join_atom_v, src);
run(); run();
CAF_CHECK_EQUAL(deref<container_sink_actor>(snk1).state.con, test_container); CAF_CHECK_EQUAL(deref<container_sink_actor>(snk1).state.con, test_container);
CAF_CHECK_EQUAL(deref<container_sink_actor>(snk2).state.con, test_container); CAF_CHECK_EQUAL(deref<container_sink_actor>(snk2).state.con, test_container);
......
...@@ -109,7 +109,7 @@ CAF_TEST(stream_to_sink) { ...@@ -109,7 +109,7 @@ CAF_TEST(stream_to_sink) {
stream_type, actor>, stream_type, actor>,
std::move(ptr_test_stream), sink); std::move(ptr_test_stream), sink);
auto mon = sys.spawn(stream_monitor); auto mon = sys.spawn(stream_monitor);
self->send(mon, join_atom::value, src); self->send(mon, join_atom_v, src);
run(); run();
CAF_CHECK_EQUAL(deref<stream_reader_sink_actor>(sink).state.vec, CAF_CHECK_EQUAL(deref<stream_reader_sink_actor>(sink).state.vec,
test_container); test_container);
...@@ -130,7 +130,7 @@ CAF_TEST(stream_to_sinks) { ...@@ -130,7 +130,7 @@ CAF_TEST(stream_to_sinks) {
stream_type, actor, actor, actor>, stream_type, actor, actor, actor>,
std::move(ptr_test_stream), snk1, snk2, snk3); std::move(ptr_test_stream), snk1, snk2, snk3);
auto mon = sys.spawn(stream_monitor); auto mon = sys.spawn(stream_monitor);
self->send(mon, join_atom::value, src); self->send(mon, join_atom_v, src);
run(); run();
CAF_CHECK_EQUAL(deref<stream_reader_sink_actor>(snk1).state.vec, CAF_CHECK_EQUAL(deref<stream_reader_sink_actor>(snk1).state.vec,
test_container); test_container);
...@@ -151,7 +151,7 @@ CAF_TEST(error_stream_to_sink) { ...@@ -151,7 +151,7 @@ CAF_TEST(error_stream_to_sink) {
stream_type, actor>, stream_type, actor>,
std::move(ptr_test_stream), sink); std::move(ptr_test_stream), sink);
auto mon = sys.spawn(stream_monitor); auto mon = sys.spawn(stream_monitor);
self->send(mon, join_atom::value, src); self->send(mon, join_atom_v, src);
run(); run();
} }
......
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