Commit 614c38c7 authored by Dominik Charousset's avatar Dominik Charousset

Fix shadowing warning

parent 6efb587a
...@@ -266,19 +266,21 @@ struct stream_multiplexer_state { ...@@ -266,19 +266,21 @@ struct stream_multiplexer_state {
const char* stream_multiplexer_state::name = "stream_multiplexer"; const char* stream_multiplexer_state::name = "stream_multiplexer";
behavior stream_multiplexer(stateful_actor<stream_multiplexer_state>* self) { behavior stream_multiplexer(stateful_actor<stream_multiplexer_state>* self) {
auto process = [](unit_t&, downstream<int>& out, int x) { { // extra scope for hiding state for initialization from the lambdas below
out.push(x); auto process = [](unit_t&, downstream<int>& out, int x) {
}; out.push(x);
auto cleanup = [](unit_t&) { };
// nop auto cleanup = [](unit_t&) {
}; // nop
auto sid = self->make_stream_id(); };
using impl = stream_stage_impl<decltype(process), decltype(cleanup), auto sid = self->make_stream_id();
detail::pull5_gatherer, using impl = stream_stage_impl<decltype(process), decltype(cleanup),
detail::push5_scatterer<int>>; detail::pull5_gatherer,
self->state.stage = make_counted<impl>(self, sid, process, cleanup); detail::push5_scatterer<int>>;
self->state.stage->in().continuous(true); self->state.stage = make_counted<impl>(self, sid, process, cleanup);
self->streams().emplace(sid, self->state.stage); self->state.stage->in().continuous(true);
self->streams().emplace(sid, self->state.stage);
}
return { return {
[=](join_atom) -> stream<int> { [=](join_atom) -> stream<int> {
CAF_MESSAGE("received 'join' request"); CAF_MESSAGE("received 'join' request");
......
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