deploy: d90e39e

v2/docs/html/annotated.html

@@ -199,7 +199,7 @@
 <tr id="row_0_2_0_30_" class="odd" style="display:none;"><td class="entry"><span style="width:48px;display:inline-block;">&#160;</span><span id="arr_0_2_0_30_" class="arrow" onclick="dynsection.toggleFolder('0_2_0_30_')">&#9658;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="structrpp_1_1operators_1_1details_1_1first__t.html" target="_self">first_t</a></td><td class="desc"></td></tr>
 <tr id="row_0_2_0_30_0_" class="odd" style="display:none;"><td class="entry"><span style="width:80px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="structrpp_1_1operators_1_1details_1_1first__t_1_1operator__traits.html" target="_self">operator_traits</a></td><td class="desc"></td></tr>
 <tr id="row_0_2_0_31_" class="odd" style="display:none;"><td class="entry"><span style="width:64px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="structrpp_1_1operators_1_1details_1_1flat__map__t.html" target="_self">flat_map_t</a></td><td class="desc"></td></tr>
-<tr id="row_0_2_0_32_" class="odd" style="display:none;"><td class="entry"><span style="width:64px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="classrpp_1_1operators_1_1details_1_1forwarding__strategy.html" target="_self">forwarding_strategy</a></td><td class="desc"></td></tr>
+<tr id="row_0_2_0_32_" class="odd" style="display:none;"><td class="entry"><span style="width:64px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="classrpp_1_1operators_1_1details_1_1forwarding__subject.html" target="_self">forwarding_subject</a></td><td class="desc"></td></tr>
 <tr id="row_0_2_0_33_" class="odd" style="display:none;"><td class="entry"><span style="width:64px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="structrpp_1_1operators_1_1details_1_1group__by__inner__observer__strategy.html" target="_self">group_by_inner_observer_strategy</a></td><td class="desc"></td></tr>
 <tr id="row_0_2_0_34_" class="odd" style="display:none;"><td class="entry"><span style="width:64px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="structrpp_1_1operators_1_1details_1_1group__by__observable__strategy.html" target="_self">group_by_observable_strategy</a></td><td class="desc"></td></tr>
 <tr id="row_0_2_0_35_" class="odd" style="display:none;"><td class="entry"><span style="width:64px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="structrpp_1_1operators_1_1details_1_1group__by__observer__strategy.html" target="_self">group_by_observer_strategy</a></td><td class="desc"></td></tr>
@@ -323,17 +323,16 @@
 <tr id="row_0_3_9_" class="odd"><td class="entry"><span style="width:48px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="classrpp_1_1schedulers_1_1worker.html" target="_self">worker</a></td><td class="desc"></td></tr>
 <tr id="row_0_4_" class="even"><td class="entry"><span style="width:16px;display:inline-block;">&#160;</span><span id="arr_0_4_" class="arrow" onclick="dynsection.toggleFolder('0_4_')">&#9660;</span><span class="icona"><span class="icon">N</span></span><b>subjects</b></td><td class="desc"></td></tr>
 <tr id="row_0_4_0_" class="odd"><td class="entry"><span style="width:32px;display:inline-block;">&#160;</span><span id="arr_0_4_0_" class="arrow" onclick="dynsection.toggleFolder('0_4_0_')">&#9658;</span><span class="icona"><span class="icon">N</span></span><b>details</b></td><td class="desc"></td></tr>
-<tr id="row_0_4_0_0_" class="even" style="display:none;"><td class="entry"><span style="width:64px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="classrpp_1_1subjects_1_1details_1_1base__subject.html" target="_self">base_subject</a></td><td class="desc"></td></tr>
-<tr id="row_0_4_0_1_" class="even" style="display:none;"><td class="entry"><span style="width:64px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="structrpp_1_1subjects_1_1details_1_1completed.html" target="_self">completed</a></td><td class="desc"></td></tr>
-<tr id="row_0_4_0_2_" class="even" style="display:none;"><td class="entry"><span style="width:64px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="structrpp_1_1subjects_1_1details_1_1disposed.html" target="_self">disposed</a></td><td class="desc"></td></tr>
-<tr id="row_0_4_0_3_" class="even" style="display:none;"><td class="entry"><span style="width:64px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="classrpp_1_1subjects_1_1details_1_1publish__strategy.html" target="_self">publish_strategy</a></td><td class="desc"></td></tr>
-<tr id="row_0_4_0_4_" class="even" style="display:none;"><td class="entry"><span style="width:64px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="classrpp_1_1subjects_1_1details_1_1replay__strategy.html" target="_self">replay_strategy</a></td><td class="desc"></td></tr>
-<tr id="row_0_4_0_5_" class="even" style="display:none;"><td class="entry"><span style="width:64px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="classrpp_1_1subjects_1_1details_1_1serialized__strategy.html" target="_self">serialized_strategy</a></td><td class="desc"></td></tr>
-<tr id="row_0_4_0_6_" class="even" style="display:none;"><td class="entry"><span style="width:64px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="classrpp_1_1subjects_1_1details_1_1subject__state.html" target="_self">subject_state</a></td><td class="desc"></td></tr>
+<tr id="row_0_4_0_0_" class="even" style="display:none;"><td class="entry"><span style="width:64px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="structrpp_1_1subjects_1_1details_1_1completed.html" target="_self">completed</a></td><td class="desc"></td></tr>
+<tr id="row_0_4_0_1_" class="even" style="display:none;"><td class="entry"><span style="width:64px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="structrpp_1_1subjects_1_1details_1_1disposed.html" target="_self">disposed</a></td><td class="desc"></td></tr>
+<tr id="row_0_4_0_2_" class="even" style="display:none;"><td class="entry"><span style="width:64px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="classrpp_1_1subjects_1_1details_1_1publish__subject__base.html" target="_self">publish_subject_base</a></td><td class="desc"></td></tr>
+<tr id="row_0_4_0_3_" class="even" style="display:none;"><td class="entry"><span style="width:64px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="classrpp_1_1subjects_1_1details_1_1replay__subject__base.html" target="_self">replay_subject_base</a></td><td class="desc"></td></tr>
+<tr id="row_0_4_0_4_" class="even" style="display:none;"><td class="entry"><span style="width:64px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="structrpp_1_1subjects_1_1details_1_1subject__on__subscribe__strategy.html" target="_self">subject_on_subscribe_strategy</a></td><td class="desc"></td></tr>
+<tr id="row_0_4_0_5_" class="even" style="display:none;"><td class="entry"><span style="width:64px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="classrpp_1_1subjects_1_1details_1_1subject__state.html" target="_self">subject_state</a></td><td class="desc"></td></tr>
 <tr id="row_0_4_1_" class="even"><td class="entry"><span style="width:48px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="classrpp_1_1subjects_1_1publish__subject.html" target="_self">publish_subject</a></td><td class="desc">Subject which just multicasts values to observers subscribed on it. It contains two parts: observer and observable at the same time </td></tr>
 <tr id="row_0_4_2_" class="odd"><td class="entry"><span style="width:48px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="classrpp_1_1subjects_1_1replay__subject.html" target="_self">replay_subject</a></td><td class="desc">Same as <a class="el" href="classrpp_1_1subjects_1_1publish__subject.html" title="Subject which just multicasts values to observers subscribed on it. It contains two parts: observer a...">rpp::subjects::publish_subject</a> but send all earlier emitted values to any new observers </td></tr>
-<tr id="row_0_4_3_" class="even"><td class="entry"><span style="width:48px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="classrpp_1_1subjects_1_1serialized__replay__subject.html" target="_self">serialized_replay_subject</a></td><td class="desc">Same as <a class="el" href="classrpp_1_1subjects_1_1replay__subject.html" title="Same as rpp::subjects::publish_subject but send all earlier emitted values to any new observers.">rpp::subjects::replay_subject</a> but on_next/on_error/on_completed calls are serialized via mutex </td></tr>
-<tr id="row_0_4_4_" class="odd"><td class="entry"><span style="width:48px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="classrpp_1_1subjects_1_1serialized__subject.html" target="_self">serialized_subject</a></td><td class="desc">Same as <a class="el" href="classrpp_1_1subjects_1_1publish__subject.html" title="Subject which just multicasts values to observers subscribed on it. It contains two parts: observer a...">rpp::subjects::publish_subject</a>, but on_next/on_error/on_completed calls are serialized via mutex </td></tr>
+<tr id="row_0_4_3_" class="even"><td class="entry"><span style="width:48px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="classrpp_1_1subjects_1_1serialized__publish__subject.html" target="_self">serialized_publish_subject</a></td><td class="desc">Serialized version of <a class="el" href="classrpp_1_1subjects_1_1publish__subject.html" title="Subject which just multicasts values to observers subscribed on it. It contains two parts: observer a...">rpp::subjects::publish_subject</a> </td></tr>
+<tr id="row_0_4_4_" class="odd"><td class="entry"><span style="width:48px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="classrpp_1_1subjects_1_1serialized__replay__subject.html" target="_self">serialized_replay_subject</a></td><td class="desc">Same as <a class="el" href="classrpp_1_1subjects_1_1replay__subject.html" title="Same as rpp::subjects::publish_subject but send all earlier emitted values to any new observers.">rpp::subjects::replay_subject</a> but on_next/on_error/on_completed calls are serialized via mutex </td></tr>
 <tr id="row_0_5_" class="even"><td class="entry"><span style="width:32px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="classrpp_1_1blocking__observable.html" target="_self">blocking_observable</a></td><td class="desc">Extension over <a class="el" href="classrpp_1_1observable.html" title="Base class for any observable used in RPP. It handles core callbacks of observable.">rpp::observable</a> with set of blocking operators - it waits till completion of underlying observable </td></tr>
 <tr id="row_0_6_" class="odd"><td class="entry"><span style="width:32px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="classrpp_1_1callback__disposable.html" target="_self">callback_disposable</a></td><td class="desc">Disposable invokes underlying callable on disposing </td></tr>
 <tr id="row_0_7_" class="even"><td class="entry"><span style="width:32px;display:inline-block;">&#160;</span><span class="icona"><span class="icon">C</span></span><a class="el" href="classrpp_1_1composite__disposable.html" target="_self">composite_disposable</a></td><td class="desc"></td></tr>

v2/docs/html/annotated_dup.js

@@ -91,7 +91,7 @@ var annotated_dup =
           [ "first_observer_strategy", "structrpp_1_1operators_1_1details_1_1first__observer__strategy.html", null ],
           [ "first_t", "structrpp_1_1operators_1_1details_1_1first__t.html", "structrpp_1_1operators_1_1details_1_1first__t" ],
           [ "flat_map_t", "structrpp_1_1operators_1_1details_1_1flat__map__t.html", null ],
-          [ "forwarding_strategy", "classrpp_1_1operators_1_1details_1_1forwarding__strategy.html", null ],
+          [ "forwarding_subject", "classrpp_1_1operators_1_1details_1_1forwarding__subject.html", null ],
           [ "group_by_inner_observer_strategy", "structrpp_1_1operators_1_1details_1_1group__by__inner__observer__strategy.html", null ],
           [ "group_by_observable_strategy", "structrpp_1_1operators_1_1details_1_1group__by__observable__strategy.html", null ],
           [ "group_by_observer_strategy", "structrpp_1_1operators_1_1details_1_1group__by__observer__strategy.html", null ],
@@ -197,18 +197,17 @@ var annotated_dup =
       ] ],
       [ "subjects", null, [
         [ "details", null, [
-          [ "base_subject", "classrpp_1_1subjects_1_1details_1_1base__subject.html", null ],
           [ "completed", "structrpp_1_1subjects_1_1details_1_1completed.html", null ],
           [ "disposed", "structrpp_1_1subjects_1_1details_1_1disposed.html", null ],
-          [ "publish_strategy", "classrpp_1_1subjects_1_1details_1_1publish__strategy.html", null ],
-          [ "replay_strategy", "classrpp_1_1subjects_1_1details_1_1replay__strategy.html", null ],
-          [ "serialized_strategy", "classrpp_1_1subjects_1_1details_1_1serialized__strategy.html", null ],
+          [ "publish_subject_base", "classrpp_1_1subjects_1_1details_1_1publish__subject__base.html", null ],
+          [ "replay_subject_base", "classrpp_1_1subjects_1_1details_1_1replay__subject__base.html", null ],
+          [ "subject_on_subscribe_strategy", "structrpp_1_1subjects_1_1details_1_1subject__on__subscribe__strategy.html", null ],
           [ "subject_state", "classrpp_1_1subjects_1_1details_1_1subject__state.html", null ]
         ] ],
         [ "publish_subject", "classrpp_1_1subjects_1_1publish__subject.html", null ],
         [ "replay_subject", "classrpp_1_1subjects_1_1replay__subject.html", null ],
-        [ "serialized_replay_subject", "classrpp_1_1subjects_1_1serialized__replay__subject.html", null ],
-        [ "serialized_subject", "classrpp_1_1subjects_1_1serialized__subject.html", null ]
+        [ "serialized_publish_subject", "classrpp_1_1subjects_1_1serialized__publish__subject.html", null ],
+        [ "serialized_replay_subject", "classrpp_1_1subjects_1_1serialized__replay__subject.html", null ]
       ] ],
       [ "blocking_observable", "classrpp_1_1blocking__observable.html", null ],
       [ "callback_disposable", "classrpp_1_1callback__disposable.html", null ],

v2/docs/html/chain__strategy_8hpp_source.html

@@ -203,8 +203,8 @@
 <div class="line"><a id="l00092" name="l00092"></a><span class="lineno">   92</span>} <span class="comment">// namespace rpp</span></div>
 <div class="ttc" id="aclassrpp_1_1observable__chain__strategy_html"><div class="ttname"><a href="classrpp_1_1observable__chain__strategy.html">rpp::observable_chain_strategy</a></div><div class="ttdef"><b>Definition</b> chain_strategy.hpp:21</div></div>
 <div class="ttc" id="aclassrpp_1_1observer_html"><div class="ttname"><a href="classrpp_1_1observer.html">rpp::observer</a></div><div class="ttdoc">Base class for any observer used in RPP. It handles core callbacks of observers. Objects of this clas...</div><div class="ttdef"><b>Definition</b> observer.hpp:173</div></div>
-<div class="ttc" id="aconceptrpp_1_1constraint_1_1operator__lift__with__disposable__strategy_html"><div class="ttname"><a href="conceptrpp_1_1constraint_1_1operator__lift__with__disposable__strategy.html">rpp::constraint::operator_lift_with_disposable_strategy</a></div><div class="ttdef"><b>Definition</b> fwd.hpp:113</div></div>
-<div class="ttc" id="aconceptrpp_1_1constraint_1_1operator__lift_html"><div class="ttname"><a href="conceptrpp_1_1constraint_1_1operator__lift.html">rpp::constraint::operator_lift</a></div><div class="ttdef"><b>Definition</b> fwd.hpp:106</div></div>
+<div class="ttc" id="aconceptrpp_1_1constraint_1_1operator__lift__with__disposable__strategy_html"><div class="ttname"><a href="conceptrpp_1_1constraint_1_1operator__lift__with__disposable__strategy.html">rpp::constraint::operator_lift_with_disposable_strategy</a></div><div class="ttdef"><b>Definition</b> fwd.hpp:112</div></div>
+<div class="ttc" id="aconceptrpp_1_1constraint_1_1operator__lift_html"><div class="ttname"><a href="conceptrpp_1_1constraint_1_1operator__lift.html">rpp::constraint::operator_lift</a></div><div class="ttdef"><b>Definition</b> fwd.hpp:105</div></div>
 <div class="ttc" id="astructrpp_1_1make__chain__observable_html"><div class="ttname"><a href="structrpp_1_1make__chain__observable.html">rpp::make_chain_observable</a></div><div class="ttdef"><b>Definition</b> chain_strategy.hpp:80</div></div>
 </div><!-- fragment --></div><!-- contents -->
 </div><!-- doc-content -->