Make new observable with items skipped until on_next occurs on the trigger observable or until the specified time. skip_until takes (TriggerObservable, optional Coordination) or (TimePoint, optional Coordination)
More...
Go to the source code of this file.
|
template<class... AN> |
auto | rxcpp::operators::skip_until (AN &&... an) -> operator_factory< skip_until_tag, AN... > |
| Make new observable with items skipped until on_next occurs on the trigger observable or until the specified time. skip_until takes (TriggerObservable, optional Coordination) or (TimePoint, optional Coordination) More...
|
|
Make new observable with items skipped until on_next occurs on the trigger observable or until the specified time. skip_until takes (TriggerObservable, optional Coordination) or (TimePoint, optional Coordination)
- Template Parameters
-
TriggerSource | the type of the trigger observable. |
Coordination | the type of the scheduler (optional). |
- Parameters
-
t | an observable that has to emit an item before the source observable's elements begin to be mirrored by the resulting observable. |
cn | the scheduler to use for scheduling the items (optional). |
- Returns
- An observable that skips items from the source observable until the second observable emits an item or the time runs out, then emits the remaining items.
- Sample Code\n
values.
[](long v){printf("OnNext: %ld\n", v);},
[](){printf("OnCompleted\n");});
- Sample Code\n
printf("[thread %s] Start task\n", get_pid().c_str());
printf("[thread %s] Source emits, value = %ld\n", get_pid().c_str(), v);
return v;
});
printf("[thread %s] Trigger emits, value = %ld\n", get_pid().c_str(), v);
return v;
});
values.
[](long v){printf("[thread %s] OnNext: %ld\n", get_pid().c_str(), v);},
[](){printf("[thread %s] OnCompleted\n", get_pid().c_str());});
printf("[thread %s] Finish task\n", get_pid().c_str());
◆ RXCPP_OPERATORS_RX_SKIP_UNTIL_HPP
#define RXCPP_OPERATORS_RX_SKIP_UNTIL_HPP |