| 205 | */ |
| 206 | template<rpp::constraint::observable TFallbackObservable, rpp::schedulers::constraint::scheduler TScheduler> |
| 207 | auto timeout(rpp::schedulers::duration period, TFallbackObservable&& fallback_observable, const TScheduler& scheduler) |
| 208 | { |
| 209 | return details::timeout_t<std::decay_t<TFallbackObservable>, TScheduler>{period, std::forward<TFallbackObservable>(fallback_observable), scheduler}; |
| 210 | } |
| 211 | |
| 212 | /** |
| 213 | * @brief Forwards emissions from original observable, but emit error if no any events during specified period of time (since last emission) |
no outgoing calls
no test coverage detected