| 237 | using boost::asio::static_thread_pool; |
| 238 | |
| 239 | void reader(queue_front<std::string> out) |
| 240 | { |
| 241 | std::string line; |
| 242 | while (std::getline(std::cin, line)) |
| 243 | out.push(line); |
| 244 | } |
| 245 | |
| 246 | void filter(queue_back<std::string> in, queue_front<std::string> out) |
| 247 | { |