Commit 2f4b8d7d authored by Hauke Goldhammer's avatar Hauke Goldhammer

Fix bb::stream_reader. Tests run now

parent 54b2c98b
...@@ -75,7 +75,7 @@ behavior stream_reader(stream_source_type<InputStream>* self, ...@@ -75,7 +75,7 @@ behavior stream_reader(stream_source_type<InputStream>* self,
using value_type = typename Policy::value_type; using value_type = typename Policy::value_type;
self->state.init(std::move(src_stream)); self->state.init(std::move(src_stream));
// Fail early if we got nothing to stream. // Fail early if we got nothing to stream.
if (!self->state.at_end()) if (self->state.at_end())
return {}; return {};
// Spin up stream manager and connect the first sink. // Spin up stream manager and connect the first sink.
auto src = self->make_source( auto src = self->make_source(
......
...@@ -53,7 +53,7 @@ TESTEE(stream_reader_sink) { ...@@ -53,7 +53,7 @@ TESTEE(stream_reader_sink) {
}, },
// Consumer // Consumer
[=](unit_t&, value_type val) { [=](unit_t&, value_type val) {
CAF_MESSAGE(self->name() << val); CAF_MESSAGE(self->name() << " " << val);
self->state.vec.emplace_back(std::move(val)); self->state.vec.emplace_back(std::move(val));
}, },
// cleanup and produce result message // cleanup and produce result message
......
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