| 245 | using boost::asio::thread_pool; |
| 246 | |
| 247 | void reader(queue_front<std::string> out) |
| 248 | { |
| 249 | std::string line; |
| 250 | while (std::getline(std::cin, line)) |
| 251 | out.push(line); |
| 252 | } |
| 253 | |
| 254 | void filter(queue_back<std::string> in, queue_front<std::string> out) |
| 255 | { |