* @example buffer.cpp **/
| 23 | * @example buffer.cpp |
| 24 | **/ |
| 25 | int main() |
| 26 | { |
| 27 | //! [buffer] |
| 28 | // The stream that uses rvalue overloads for operators |
| 29 | rpp::source::just(1, 2, 3, 4, 5) |
| 30 | | rpp::ops::buffer(2) |
| 31 | | rpp::ops::subscribe( |
| 32 | [](const std::vector<int>& v) { std::cout << v << "-"; }, |
| 33 | [](const std::exception_ptr&) {}, |
| 34 | []() { std::cout << "|" << std::endl; }); |
| 35 | // Source: -1-2-3-4-5--| |
| 36 | // Output: {1,2}-{3,4}-{5}-| |
| 37 | //! [buffer] |
| 38 | return 0; |
| 39 | } |