* @brief Subdivide original observable into sub-observables (window observables) and emit sub-observables of items instead of original items * * @marble window { source observable : +-1-2-3-4-5-| operator "window(2)" : { .+1-2| .....+3-4|
| 158 | * @see https://reactivex.io/documentation/operators/window.html |
| 159 | */ |
| 160 | inline auto window(size_t count) |
| 161 | { |
| 162 | return details::window_t{count}; |
| 163 | } |
| 164 | } // namespace rpp::operators |
no outgoing calls
no test coverage detected