Return an observable that emits connected, non-overlapping buffers of items from the source observable that were emitted during a fixed duration of time or when the buffer has reached maximum capacity (whichever occurs first), on the specified scheduler.
More...
Go to the source code of this file.
|
template<class... AN> |
auto | rxcpp::operators::buffer_with_time_or_count (AN &&...an) -> operator_factory< buffer_with_time_or_count_tag, AN... > |
| Return an observable that emits connected, non-overlapping buffers of items from the source observable that were emitted during a fixed duration of time or when the buffer has reached maximum capacity (whichever occurs first), on the specified scheduler. More...
|
|
Return an observable that emits connected, non-overlapping buffers of items from the source observable that were emitted during a fixed duration of time or when the buffer has reached maximum capacity (whichever occurs first), on the specified scheduler.
- Template Parameters
-
Duration | the type of the time interval. |
Coordination | the type of the scheduler (optional). |
- Parameters
-
period | the period of time each buffer collects items before it is emitted and replaced with a new buffer. |
count | the maximum size of each buffer before it is emitted and new buffer is created. |
coordination | the scheduler for the buffers (optional). |
- Returns
- Observable that emits connected, non-overlapping buffers of items from the source observable that were emitted during a fixed duration of time or when the buffer has reached maximum capacity (whichever occurs first).
- Sample Code
auto start = std::chrono::steady_clock::now();
auto values = int1.
values.
[start](std::vector<long> v){
printf("OnNext:");
std::for_each(v.begin(), v.end(), [](long a){
printf(" %ld", a);
});
printf("\n");
},
[](){printf("OnCompleted\n");});
OnNext: 1 2
OnNext: 3
OnNext:
OnNext: 1
OnCompleted
- Sample Code
auto start = std::chrono::steady_clock::now();
auto values = int1.
values.
[start](std::vector<long> v){
printf("OnNext:");
std::for_each(v.begin(), v.end(), [](long a){
printf(" %ld", a);
});
printf("\n");
},
[](){printf("OnCompleted\n");});
OnNext: 1 2
OnNext: 3
OnNext:
OnNext: 1
OnCompleted
#define RXCPP_OPERATORS_RX_BUFFER_WITH_TIME_OR_COUNT_HPP |