| 367 | } |
| 368 | |
| 369 | void launchGroup(const TaskGroupInfo& taskGroup) |
| 370 | { |
| 371 | CHECK_EQ(SUBSCRIBED, state); |
| 372 | |
| 373 | process::http::connect(agent) |
| 374 | .onAny(defer(self(), &Self::_launchGroup, taskGroup, lambda::_1)); |
| 375 | } |
| 376 | |
| 377 | void _launchGroup( |
| 378 | const TaskGroupInfo& taskGroup, |