Commit 9d9065a7 authored by neverlord's avatar neverlord

'next << ...' rather than next.enqueue(...)

parent b7222548
......@@ -163,7 +163,7 @@ struct fsm_chain_link : fsm_actor<fsm_chain_link>
(
on<atom("token"), int>() >> [=](int v)
{
next->enqueue(nullptr, std::move(self->last_dequeued()));
next << std::move(last_dequeued());
if (v == 0) become_void();
}
);
......@@ -249,11 +249,11 @@ void chain_link(actor_ptr next)
(
on<atom("token"), int>() >> [&](int v)
{
next << self->last_dequeued();
if (v == 0)
{
done = true;
}
next << std::move(self->last_dequeued());
}
)
.until([&]() { return done == true; });
......
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