deploy: 6def295

victimsnino · Apr 1, 2024 · 1d9f96a · 1d9f96a
1 parent ae51693
commit 1d9f96a
Show file tree

Hide file tree

Showing 83 changed files with 243 additions and 184 deletions.
diff --git a/v2/docs/html/doxygen_crawl.html b/v2/docs/html/doxygen_crawl.html
diff --git a/v2/docs/html/main__thread_8hpp_source.html b/v2/docs/html/main__thread_8hpp_source.html
diff --git a/v2/docs/latex/classrpp_1_1blocking__observable.pdf b/v2/docs/latex/classrpp_1_1blocking__observable.pdf
diff --git a/v2/docs/latex/classrpp_1_1callback__disposable.pdf b/v2/docs/latex/classrpp_1_1callback__disposable.pdf
diff --git a/v2/docs/latex/classrpp_1_1composite__disposable.pdf b/v2/docs/latex/classrpp_1_1composite__disposable.pdf
diff --git a/v2/docs/latex/classrpp_1_1composite__disposable__impl.pdf b/v2/docs/latex/classrpp_1_1composite__disposable__impl.pdf
diff --git a/v2/docs/latex/classrpp_1_1details_1_1base__disposable__impl.pdf b/v2/docs/latex/classrpp_1_1details_1_1base__disposable__impl.pdf
diff --git a/v2/docs/latex/classrpp_1_1details_1_1disposable__wrapper__base.pdf b/v2/docs/latex/classrpp_1_1details_1_1disposable__wrapper__base.pdf
diff --git a/v2/docs/latex/classrpp_1_1details_1_1disposables_1_1dynamic__disposables__container.pdf b/v2/docs/latex/classrpp_1_1details_1_1disposables_1_1dynamic__disposables__container.pdf
diff --git a/...ocs/latex/classrpp_1_1details_1_1disposables_1_1dynamic__disposables__container__base.pdf b/...ocs/latex/classrpp_1_1details_1_1disposables_1_1dynamic__disposables__container__base.pdf
diff --git a/v2/docs/latex/classrpp_1_1details_1_1observables_1_1blocking__disposble.pdf b/v2/docs/latex/classrpp_1_1details_1_1observables_1_1blocking__disposble.pdf
diff --git a/v2/docs/latex/classrpp_1_1details_1_1refocunt__disposable__inner.pdf b/v2/docs/latex/classrpp_1_1details_1_1refocunt__disposable__inner.pdf
diff --git a/v2/docs/latex/classrpp_1_1disposable__wrapper__impl.pdf b/v2/docs/latex/classrpp_1_1disposable__wrapper__impl.pdf
diff --git a/v2/docs/latex/classrpp_1_1dynamic__observable.pdf b/v2/docs/latex/classrpp_1_1dynamic__observable.pdf
diff --git a/v2/docs/latex/classrpp_1_1dynamic__observer.pdf b/v2/docs/latex/classrpp_1_1dynamic__observer.pdf
diff --git a/v2/docs/latex/classrpp_1_1grouped__observable.pdf b/v2/docs/latex/classrpp_1_1grouped__observable.pdf
diff --git a/v2/docs/latex/classrpp_1_1observable.pdf b/v2/docs/latex/classrpp_1_1observable.pdf
diff --git a/v2/docs/latex/classrpp_1_1observer.pdf b/v2/docs/latex/classrpp_1_1observer.pdf
diff --git a/...tails_1_1with__disposable__strategy_3_01_strategy_00_01_disposable_strategy_01_4_01_4.pdf b/...tails_1_1with__disposable__strategy_3_01_strategy_00_01_disposable_strategy_01_4_01_4.pdf
diff --git a/...r_3_01_type_00_01rpp_1_1details_1_1observers_1_1dynamic__strategy_3_01_type_01_4_01_4.pdf b/...r_3_01_type_00_01rpp_1_1details_1_1observers_1_1dynamic__strategy_3_01_type_01_4_01_4.pdf
diff --git a/v2/docs/latex/classrpp_1_1operators_1_1details_1_1combine__latest__disposable.pdf b/v2/docs/latex/classrpp_1_1operators_1_1details_1_1combine__latest__disposable.pdf
diff --git a/v2/docs/latex/classrpp_1_1operators_1_1details_1_1combining__disposable.pdf b/v2/docs/latex/classrpp_1_1operators_1_1details_1_1combining__disposable.pdf
diff --git a/v2/docs/latex/classrpp_1_1operators_1_1details_1_1concat__state__t.pdf b/v2/docs/latex/classrpp_1_1operators_1_1details_1_1concat__state__t.pdf
diff --git a/v2/docs/latex/classrpp_1_1operators_1_1details_1_1debounce__disposable.pdf b/v2/docs/latex/classrpp_1_1operators_1_1details_1_1debounce__disposable.pdf
diff --git a/v2/docs/latex/classrpp_1_1operators_1_1details_1_1merge__disposable.pdf b/v2/docs/latex/classrpp_1_1operators_1_1details_1_1merge__disposable.pdf
diff --git a/v2/docs/latex/classrpp_1_1operators_1_1details_1_1merge__observer__strategy.pdf b/v2/docs/latex/classrpp_1_1operators_1_1details_1_1merge__observer__strategy.pdf
diff --git a/v2/docs/latex/classrpp_1_1operators_1_1details_1_1switch__on__next__state__t.pdf b/v2/docs/latex/classrpp_1_1operators_1_1details_1_1switch__on__next__state__t.pdf
diff --git a/v2/docs/latex/classrpp_1_1operators_1_1details_1_1take__until__disposable.pdf b/v2/docs/latex/classrpp_1_1operators_1_1details_1_1take__until__disposable.pdf
diff --git a/v2/docs/latex/classrpp_1_1operators_1_1details_1_1timeout__disposable.pdf b/v2/docs/latex/classrpp_1_1operators_1_1details_1_1timeout__disposable.pdf
diff --git a/v2/docs/latex/classrpp_1_1operators_1_1details_1_1with__latest__from__disposable.pdf b/v2/docs/latex/classrpp_1_1operators_1_1details_1_1with__latest__from__disposable.pdf
diff --git a/v2/docs/latex/classrpp_1_1operators_1_1details_1_1zip__disposable.pdf b/v2/docs/latex/classrpp_1_1operators_1_1details_1_1zip__disposable.pdf
diff --git a/v2/docs/latex/classrpp_1_1refcount__disposable.pdf b/v2/docs/latex/classrpp_1_1refcount__disposable.pdf
diff --git a/v2/docs/latex/classrpp_1_1schedulers_1_1details_1_1schedulable__base.pdf b/v2/docs/latex/classrpp_1_1schedulers_1_1details_1_1schedulable__base.pdf
diff --git a/v2/docs/latex/classrpp_1_1schedulers_1_1details_1_1specific__schedulable.pdf b/v2/docs/latex/classrpp_1_1schedulers_1_1details_1_1specific__schedulable.pdf
diff --git a/v2/docs/latex/classrpp_1_1subjects_1_1details_1_1subject__state.pdf b/v2/docs/latex/classrpp_1_1subjects_1_1details_1_1subject__state.pdf
diff --git a/v2/docs/latex/classrpp_1_1subjects_1_1publish__subject.pdf b/v2/docs/latex/classrpp_1_1subjects_1_1publish__subject.pdf
diff --git a/v2/docs/latex/classrpp_1_1subjects_1_1replay__subject.pdf b/v2/docs/latex/classrpp_1_1subjects_1_1replay__subject.pdf
diff --git a/v2/docs/latex/classrpp_1_1subjects_1_1serialized__publish__subject.pdf b/v2/docs/latex/classrpp_1_1subjects_1_1serialized__publish__subject.pdf
diff --git a/v2/docs/latex/classrpp_1_1subjects_1_1serialized__replay__subject.pdf b/v2/docs/latex/classrpp_1_1subjects_1_1serialized__replay__subject.pdf
diff --git a/v2/docs/latex/main__thread_8hpp_source.tex b/v2/docs/latex/main__thread_8hpp_source.tex
@@ -19,43 +19,71 @@
 \DoxyCodeLine{00015\ \textcolor{preprocessor}{\#include\ <rppqt/schedulers/fwd.hpp>}\ \textcolor{comment}{//\ own\ forwarding}}
 \DoxyCodeLine{00016\ \textcolor{preprocessor}{\#include\ <rppqt/utils/exceptions.hpp>}}
 \DoxyCodeLine{00017\ }
-\DoxyCodeLine{00018\ \textcolor{preprocessor}{\#include\ <QCoreApplication>}}
-\DoxyCodeLine{00019\ \textcolor{preprocessor}{\#include\ <QTimer>}}
-\DoxyCodeLine{00020\ \textcolor{preprocessor}{\#include\ <chrono>}}
-\DoxyCodeLine{00021\ \textcolor{preprocessor}{\#include\ <concepts>}}
-\DoxyCodeLine{00022\ }
-\DoxyCodeLine{00023\ \textcolor{keyword}{namespace\ }rppqt::schedulers}
-\DoxyCodeLine{00024\ \{}
-\DoxyCodeLine{00029\ \ \ \ \ \textcolor{keyword}{class\ }\mbox{\hyperlink{classrppqt_1_1schedulers_1_1main__thread__scheduler}{main\_thread\_scheduler}}\ final}
-\DoxyCodeLine{00030\ \ \ \ \ \{}
-\DoxyCodeLine{00031\ \ \ \ \ \textcolor{keyword}{private}:}
-\DoxyCodeLine{00032\ \ \ \ \ \ \ \ \ \textcolor{keyword}{class\ }worker\_strategy}
-\DoxyCodeLine{00033\ \ \ \ \ \ \ \ \ \{}
-\DoxyCodeLine{00034\ \ \ \ \ \ \ \ \ \textcolor{keyword}{public}:}
-\DoxyCodeLine{00035\ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keyword}{template}<\mbox{\hyperlink{conceptrpp_1_1schedulers_1_1constraint_1_1schedulable__handler}{rpp::schedulers::constraint::schedulable\_handler}}\ Handler,\ \textcolor{keyword}{typename}...\ Args,\ \mbox{\hyperlink{conceptrpp_1_1schedulers_1_1constraint_1_1schedulable__fn}{rpp::schedulers::constraint::schedulable\_fn}}<Handler,\ Args...>\ Fn>}
-\DoxyCodeLine{00036\ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keyword}{static}\ \textcolor{keywordtype}{void}\ defer\_for(rpp::schedulers::duration\ duration,\ Fn\&\&\ fn,\ Handler\&\&\ handler,\ Args\&\&...\ args)}
-\DoxyCodeLine{00037\ \ \ \ \ \ \ \ \ \ \ \ \ \{}
-\DoxyCodeLine{00038\ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keyword}{const}\ \textcolor{keyword}{auto}\ application\ =\ QCoreApplication::instance();}
-\DoxyCodeLine{00039\ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keywordflow}{if}\ (!application)}
-\DoxyCodeLine{00040\ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keywordflow}{throw}\ \mbox{\hyperlink{structrppqt_1_1utils_1_1no__active__qapplication}{utils::no\_active\_qapplication}}\{\textcolor{stringliteral}{"{}Pointer\ to\ application\ is\ null.\ Create\ QApplication\ before\ using\ main\_thread\_scheduler!"{}}\};}
-\DoxyCodeLine{00041\ }
-\DoxyCodeLine{00042\ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ QTimer::singleShot(std::chrono::duration\_cast<std::chrono::milliseconds>(duration),\ application,\ [fn\ =\ std::forward<Fn>(fn),\ handler\ =\ std::forward<Handler>(handler),\ ...\ args\ =\ std::forward<Args>(args)]()\ \textcolor{keyword}{mutable}\ \{}
-\DoxyCodeLine{00043\ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keywordflow}{if}\ (\textcolor{keyword}{const}\ \textcolor{keyword}{auto}\ new\_duration\ =\ fn(handler,\ args...))}
-\DoxyCodeLine{00044\ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ defer\_for(new\_duration-\/>value,\ std::move(fn),\ std::move(handler),\ std::move(args)...);}
-\DoxyCodeLine{00045\ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \});}
-\DoxyCodeLine{00046\ \ \ \ \ \ \ \ \ \ \ \ \ \}}
-\DoxyCodeLine{00047\ }
-\DoxyCodeLine{00048\ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keyword}{static}\ \textcolor{keyword}{constexpr}\ \mbox{\hyperlink{structrpp_1_1schedulers_1_1details_1_1none__disposable}{rpp::schedulers::details::none\_disposable}}\ get\_disposable()\ \{\ \textcolor{keywordflow}{return}\ \{\};\ \}}
-\DoxyCodeLine{00049\ }
-\DoxyCodeLine{00050\ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keyword}{static}\ rpp::schedulers::time\_point\ now()\ \{\ \textcolor{keywordflow}{return}\ rpp::schedulers::clock\_type::now();\ \}}
-\DoxyCodeLine{00051\ \ \ \ \ \ \ \ \ \};}
+\DoxyCodeLine{00018\ \textcolor{preprocessor}{\#include\ "{}rpp/schedulers/fwd.hpp"{}}}
+\DoxyCodeLine{00019\ }
+\DoxyCodeLine{00020\ \textcolor{preprocessor}{\#include\ <QCoreApplication>}}
+\DoxyCodeLine{00021\ \textcolor{preprocessor}{\#include\ <QTimer>}}
+\DoxyCodeLine{00022\ \textcolor{preprocessor}{\#include\ <chrono>}}
+\DoxyCodeLine{00023\ \textcolor{preprocessor}{\#include\ <concepts>}}
+\DoxyCodeLine{00024\ }
+\DoxyCodeLine{00025\ \textcolor{keyword}{namespace\ }rppqt::schedulers}
+\DoxyCodeLine{00026\ \{}
+\DoxyCodeLine{00031\ \ \ \ \ \textcolor{keyword}{class\ }\mbox{\hyperlink{classrppqt_1_1schedulers_1_1main__thread__scheduler}{main\_thread\_scheduler}}\ final}
+\DoxyCodeLine{00032\ \ \ \ \ \{}
+\DoxyCodeLine{00033\ \ \ \ \ \textcolor{keyword}{private}:}
+\DoxyCodeLine{00034\ \ \ \ \ \ \ \ \ \textcolor{keyword}{class\ }worker\_strategy}
+\DoxyCodeLine{00035\ \ \ \ \ \ \ \ \ \{}
+\DoxyCodeLine{00036\ \ \ \ \ \ \ \ \ \textcolor{keyword}{public}:}
+\DoxyCodeLine{00037\ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keyword}{template}<\mbox{\hyperlink{conceptrpp_1_1schedulers_1_1constraint_1_1schedulable__handler}{rpp::schedulers::constraint::schedulable\_handler}}\ Handler,\ \textcolor{keyword}{typename}...\ Args,\ \mbox{\hyperlink{conceptrpp_1_1schedulers_1_1constraint_1_1schedulable__fn}{rpp::schedulers::constraint::schedulable\_fn}}<Handler,\ Args...>\ Fn>}
+\DoxyCodeLine{00038\ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keyword}{static}\ \textcolor{keywordtype}{void}\ defer\_for(rpp::schedulers::duration\ duration,\ Fn\&\&\ fn,\ Handler\&\&\ handler,\ Args\&\&...\ args)}
+\DoxyCodeLine{00039\ \ \ \ \ \ \ \ \ \ \ \ \ \{}
+\DoxyCodeLine{00040\ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keyword}{const}\ \textcolor{keyword}{auto}\ application\ =\ QCoreApplication::instance();}
+\DoxyCodeLine{00041\ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keywordflow}{if}\ (!application)}
+\DoxyCodeLine{00042\ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \{}
+\DoxyCodeLine{00043\ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ handler.on\_error(std::make\_exception\_ptr(\mbox{\hyperlink{structrppqt_1_1utils_1_1no__active__qapplication}{utils::no\_active\_qapplication}}\{\textcolor{stringliteral}{"{}Pointer\ to\ application\ is\ null.\ Create\ QApplication\ before\ using\ main\_thread\_scheduler!"{}}\}));}
+\DoxyCodeLine{00044\ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keywordflow}{return};}
+\DoxyCodeLine{00045\ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \}}
+\DoxyCodeLine{00046\ }
+\DoxyCodeLine{00047\ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ QTimer::singleShot(std::chrono::duration\_cast<std::chrono::milliseconds>(duration),\ application,\ [fn\ =\ std::forward<Fn>(fn),\ handler\ =\ std::forward<Handler>(handler),\ ...\ args\ =\ std::forward<Args>(args)]()\ \textcolor{keyword}{mutable}\ \{}
+\DoxyCodeLine{00048\ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keywordflow}{if}\ (!handler.is\_disposed())}
+\DoxyCodeLine{00049\ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ invoke(std::move(fn),\ std::move(handler),\ std::move(args)...);}
+\DoxyCodeLine{00050\ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \});}
+\DoxyCodeLine{00051\ \ \ \ \ \ \ \ \ \ \ \ \ \}}
 \DoxyCodeLine{00052\ }
-\DoxyCodeLine{00053\ \ \ \ \ \textcolor{keyword}{public}:}
-\DoxyCodeLine{00054\ \ \ \ \ \ \ \ \ \textcolor{keyword}{static}\ \textcolor{keyword}{auto}\ create\_worker()}
-\DoxyCodeLine{00055\ \ \ \ \ \ \ \ \ \{}
-\DoxyCodeLine{00056\ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keywordflow}{return}\ \mbox{\hyperlink{classrpp_1_1schedulers_1_1worker}{rpp::schedulers::worker<worker\_strategy>}}\{\};}
-\DoxyCodeLine{00057\ \ \ \ \ \ \ \ \ \}}
-\DoxyCodeLine{00058\ \ \ \ \ \};}
-\DoxyCodeLine{00059\ \}\ \textcolor{comment}{//\ namespace\ rppqt::schedulers}}
+\DoxyCodeLine{00053\ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keyword}{static}\ \textcolor{keyword}{constexpr}\ \mbox{\hyperlink{structrpp_1_1schedulers_1_1details_1_1none__disposable}{rpp::schedulers::details::none\_disposable}}\ get\_disposable()\ \{\ \textcolor{keywordflow}{return}\ \{\};\ \}}
+\DoxyCodeLine{00054\ }
+\DoxyCodeLine{00055\ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keyword}{static}\ rpp::schedulers::time\_point\ now()\ \{\ \textcolor{keywordflow}{return}\ rpp::schedulers::clock\_type::now();\ \}}
+\DoxyCodeLine{00056\ }
+\DoxyCodeLine{00057\ \ \ \ \ \ \ \ \ \textcolor{keyword}{private}:}
+\DoxyCodeLine{00058\ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keyword}{template}<\mbox{\hyperlink{conceptrpp_1_1schedulers_1_1constraint_1_1schedulable__handler}{rpp::schedulers::constraint::schedulable\_handler}}\ Handler,\ \textcolor{keyword}{typename}...\ Args,\ \mbox{\hyperlink{conceptrpp_1_1schedulers_1_1constraint_1_1schedulable__delay__from__now__fn}{rpp::schedulers::constraint::schedulable\_delay\_from\_now\_fn}}<Handler,\ Args...>\ Fn>}
+\DoxyCodeLine{00059\ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keyword}{static}\ \textcolor{keywordtype}{void}\ invoke(Fn\&\&\ fn,\ Handler\&\&\ handler,\ Args\&\&...\ args)}
+\DoxyCodeLine{00060\ \ \ \ \ \ \ \ \ \ \ \ \ \{}
+\DoxyCodeLine{00061\ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keywordflow}{if}\ (\textcolor{keyword}{const}\ \textcolor{keyword}{auto}\ new\_duration\ =\ fn(handler,\ args...))}
+\DoxyCodeLine{00062\ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ defer\_for(new\_duration-\/>value,\ std::forward<Fn>(fn),\ std::forward<Handler>(handler),\ std::forward<Args>(args)...);}
+\DoxyCodeLine{00063\ \ \ \ \ \ \ \ \ \ \ \ \ \}}
+\DoxyCodeLine{00064\ }
+\DoxyCodeLine{00065\ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keyword}{template}<\mbox{\hyperlink{conceptrpp_1_1schedulers_1_1constraint_1_1schedulable__handler}{rpp::schedulers::constraint::schedulable\_handler}}\ Handler,\ \textcolor{keyword}{typename}...\ Args,\ \mbox{\hyperlink{conceptrpp_1_1schedulers_1_1constraint_1_1schedulable__delay__from__this__timepoint__fn}{rpp::schedulers::constraint::schedulable\_delay\_from\_this\_timepoint\_fn}}<Handler,\ Args...>\ Fn>}
+\DoxyCodeLine{00066\ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keyword}{static}\ \textcolor{keywordtype}{void}\ invoke(Fn\&\&\ fn,\ Handler\&\&\ handler,\ Args\&\&...\ args)}
+\DoxyCodeLine{00067\ \ \ \ \ \ \ \ \ \ \ \ \ \{}
+\DoxyCodeLine{00068\ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keyword}{const}\ \textcolor{keyword}{auto}\ now\ =\ rpp::schedulers::clock\_type::now();}
+\DoxyCodeLine{00069\ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keywordflow}{if}\ (\textcolor{keyword}{const}\ \textcolor{keyword}{auto}\ new\_duration\ =\ fn(handler,\ args...))}
+\DoxyCodeLine{00070\ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ defer\_for(now\ +\ new\_duration-\/>value\ -\/\ rpp::schedulers::clock\_type::now(),\ std::forward<Fn>(fn),\ std::forward<Handler>(handler),\ std::forward<Args>(args)...);}
+\DoxyCodeLine{00071\ \ \ \ \ \ \ \ \ \ \ \ \ \}}
+\DoxyCodeLine{00072\ }
+\DoxyCodeLine{00073\ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keyword}{template}<\mbox{\hyperlink{conceptrpp_1_1schedulers_1_1constraint_1_1schedulable__handler}{rpp::schedulers::constraint::schedulable\_handler}}\ Handler,\ \textcolor{keyword}{typename}...\ Args,\ \mbox{\hyperlink{conceptrpp_1_1schedulers_1_1constraint_1_1schedulable__delay__to__fn}{rpp::schedulers::constraint::schedulable\_delay\_to\_fn}}<Handler,\ Args...>\ Fn>}
+\DoxyCodeLine{00074\ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keyword}{static}\ \textcolor{keywordtype}{void}\ invoke(Fn\&\&\ fn,\ Handler\&\&\ handler,\ Args\&\&...\ args)}
+\DoxyCodeLine{00075\ \ \ \ \ \ \ \ \ \ \ \ \ \{}
+\DoxyCodeLine{00076\ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keywordflow}{if}\ (\textcolor{keyword}{const}\ \textcolor{keyword}{auto}\ new\_tp\ =\ fn(handler,\ args...))}
+\DoxyCodeLine{00077\ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ \ defer\_for(new\_tp-\/>value\ -\/\ rpp::schedulers::clock\_type::now(),\ std::forward<Fn>(fn),\ std::forward<Handler>(handler),\ std::forward<Args>(args)...);}
+\DoxyCodeLine{00078\ \ \ \ \ \ \ \ \ \ \ \ \ \}}
+\DoxyCodeLine{00079\ \ \ \ \ \ \ \ \ \};}
+\DoxyCodeLine{00080\ }
+\DoxyCodeLine{00081\ \ \ \ \ \textcolor{keyword}{public}:}
+\DoxyCodeLine{00082\ \ \ \ \ \ \ \ \ \textcolor{keyword}{static}\ \textcolor{keyword}{auto}\ create\_worker()}
+\DoxyCodeLine{00083\ \ \ \ \ \ \ \ \ \{}
+\DoxyCodeLine{00084\ \ \ \ \ \ \ \ \ \ \ \ \ \textcolor{keywordflow}{return}\ \mbox{\hyperlink{classrpp_1_1schedulers_1_1worker}{rpp::schedulers::worker<worker\_strategy>}}\{\};}
+\DoxyCodeLine{00085\ \ \ \ \ \ \ \ \ \}}
+\DoxyCodeLine{00086\ \ \ \ \ \};}
+\DoxyCodeLine{00087\ \}\ \textcolor{comment}{//\ namespace\ rppqt::schedulers}}
 
 \end{DoxyCode}
diff --git a/v2/docs/latex/structrpp_1_1details_1_1concat__state__t.pdf b/v2/docs/latex/structrpp_1_1details_1_1concat__state__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1interface__composite__disposable.pdf b/v2/docs/latex/structrpp_1_1interface__composite__disposable.pdf
diff --git a/v2/docs/latex/structrpp_1_1interface__disposable.pdf b/v2/docs/latex/structrpp_1_1interface__disposable.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1buffer__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1buffer__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1combine__latest__observer__strategy.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1combine__latest__observer__strategy.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1combine__latest__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1combine__latest__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1concat__inner__observer__strategy.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1concat__inner__observer__strategy.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1concat__observer__strategy.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1concat__observer__strategy.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1concat__observer__strategy__base.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1concat__observer__strategy__base.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1concat__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1concat__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1delay__disposable.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1delay__disposable.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1distinct__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1distinct__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1distinct__until__changed__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1distinct__until__changed__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1filter__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1filter__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1first__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1first__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1group__by__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1group__by__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1last__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1last__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1map__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1map__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1merge__observer__base__strategy.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1merge__observer__base__strategy.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1merge__observer__inner__strategy.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1merge__observer__inner__strategy.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1merge__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1merge__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1on__error__resume__next__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1on__error__resume__next__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1reduce__no__seed__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1reduce__no__seed__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1reduce__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1reduce__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1scan__no__seed__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1scan__no__seed__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1scan__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1scan__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1skip__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1skip__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1switch__on__next__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1switch__on__next__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1take__last__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1take__last__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1take__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1take__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1take__until__observer__strategy.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1take__until__observer__strategy.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1take__until__observer__strategy__base.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1take__until__observer__strategy__base.pdf
diff --git a/.../latex/structrpp_1_1operators_1_1details_1_1take__until__throttle__observer__strategy.pdf b/.../latex/structrpp_1_1operators_1_1details_1_1take__until__throttle__observer__strategy.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1take__while__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1take__while__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1tap__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1tap__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1throttle__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1throttle__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1window__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1window__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1window__toggle__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1window__toggle__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1zip__observer__strategy.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1zip__observer__strategy.pdf
diff --git a/v2/docs/latex/structrpp_1_1operators_1_1details_1_1zip__t.pdf b/v2/docs/latex/structrpp_1_1operators_1_1details_1_1zip__t.pdf
diff --git a/v2/docs/latex/structrpp_1_1schedulers_1_1constraint_1_1details_1_1is__worker.pdf b/v2/docs/latex/structrpp_1_1schedulers_1_1constraint_1_1details_1_1is__worker.pdf
diff --git a/...aint_1_1details_1_1is__worker_3_01rpp_1_1schedulers_1_1worker_3_01_strategy_01_4_01_4.pdf b/...aint_1_1details_1_1is__worker_3_01rpp_1_1schedulers_1_1worker_3_01_strategy_01_4_01_4.pdf
diff --git a/v2/docs/latex/structrppqt_1_1utils_1_1no__active__qapplication.pdf b/v2/docs/latex/structrppqt_1_1utils_1_1no__active__qapplication.pdf