MCPcopy Create free account
hub / github.com/AlexInLog/ReactivePlusPlus / timeout

Function timeout

src/rpp/rpp/operators/timeout.hpp:207–210  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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)

Callers 2

test_timeout.cppFile · 0.85
mainFunction · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected