AlexInLog · AlexInLog · Dec 26, 2023 · Dec 26, 2023 · Dec 26, 2023
diff --git a/src/rpp/rpp/disposables/callback_disposable.hpp b/src/rpp/rpp/disposables/callback_disposable.hpp
@@ -11,14 +11,13 @@
 #pragma once
 
 #include <rpp/disposables/fwd.hpp>
-
 #include <rpp/disposables/details/base_disposable.hpp>
 
 namespace rpp
 {
 /**
  * @brief Disposable invokes underlying callable on disposing.
- * 
+ *
  * @ingroup disposables
  */
 template<rpp::constraint::is_nothrow_invocable Fn>

diff --git a/src/rpp/rpp/disposables/composite_disposable.hpp b/src/rpp/rpp/disposables/composite_disposable.hpp
@@ -18,7 +18,6 @@
 
 #include <atomic>
 #include <memory>
-#include <vector>
 
 namespace rpp
 {

diff --git a/src/rpp/rpp/disposables/details/base_disposable.hpp b/src/rpp/rpp/disposables/details/base_disposable.hpp
@@ -11,7 +11,6 @@
 #pragma once
 
 #include <rpp/disposables/fwd.hpp>
-
 #include <rpp/disposables/interface_disposable.hpp>
 
 #include <atomic>

diff --git a/src/rpp/rpp/disposables/disposable_wrapper.hpp b/src/rpp/rpp/disposables/disposable_wrapper.hpp
@@ -11,7 +11,6 @@
 #pragma once
 
 #include <rpp/disposables/fwd.hpp>
-
 #include <rpp/disposables/interface_disposable.hpp>
 
 #include <memory>

diff --git a/src/rpp/rpp/disposables/fwd.hpp b/src/rpp/rpp/disposables/fwd.hpp
@@ -12,8 +12,6 @@
 
 #include <rpp/utils/constraints.hpp>
 
-#include <concepts>
-
 namespace rpp
 {
 struct interface_disposable;

diff --git a/src/rpp/rpp/disposables/interface_composite_disposable.hpp b/src/rpp/rpp/disposables/interface_composite_disposable.hpp
@@ -14,8 +14,6 @@
 #include <rpp/disposables/disposable_wrapper.hpp>
 #include <rpp/disposables/interface_disposable.hpp>
 
-#include <memory>
-
 namespace rpp
 {
 struct interface_composite_disposable : public interface_disposable

diff --git a/src/rpp/rpp/observers/details/disposable_strategy.hpp b/src/rpp/rpp/observers/details/disposable_strategy.hpp
@@ -16,7 +16,6 @@
 #include <rpp/disposables/disposable_wrapper.hpp>
 
 #include <atomic>
-#include <vector>
 
 namespace rpp::details::observers
 {
@@ -29,7 +28,7 @@ class atomic_bool
         : m_value{other.m_value.load(std::memory_order::seq_cst)}
     {}
 
-    bool test() const noexcept 
+    bool test() const noexcept
     {
         // just need atomicity, not guarding anything
         return m_value.load(std::memory_order::seq_cst);
@@ -50,7 +49,7 @@ class non_atomic_bool
     non_atomic_bool() = default;
     non_atomic_bool(non_atomic_bool&& other) noexcept = default;
 
-    bool test() const noexcept 
+    bool test() const noexcept
     {
         return m_value;
     }

diff --git a/src/rpp/rpp/observers/observer.hpp b/src/rpp/rpp/observers/observer.hpp
@@ -22,8 +22,6 @@
 #include <rpp/utils/utils.hpp>
 
 #include <exception>
-#include <stdexcept>
-#include <type_traits>
 
 namespace rpp::details
 {

diff --git a/src/rpp/rpp/operators/combine_latest.hpp b/src/rpp/rpp/operators/combine_latest.hpp
@@ -19,7 +19,6 @@
 #include <rpp/schedulers/current_thread.hpp>
 
 #include <memory>
-#include <tuple>
 
 namespace rpp::operators::details
 {

diff --git a/src/rpp/rpp/operators/first.hpp b/src/rpp/rpp/operators/first.hpp
@@ -15,8 +15,6 @@
 #include <rpp/defs.hpp>
 #include <rpp/operators/details/strategy.hpp>
 
-#include <cstddef>
-
 namespace rpp::operators::details
 {
 template<rpp::constraint::observer TObserver>

diff --git a/src/rpp/rpp/operators/flat_map.hpp b/src/rpp/rpp/operators/flat_map.hpp
@@ -16,7 +16,6 @@
 
 namespace rpp::operators::details
 {
-
 template<rpp::constraint::decayed_type Fn>
 struct flat_map_t
 {
@@ -58,9 +57,9 @@ namespace rpp::operators
         }
  *
  * @details Actually it makes `map(callable)` and then `merge`.
- * @details Note that flat_map merges the emissions of these Observables, so that they may interleave. 
+ * @details Note that flat_map merges the emissions of these Observables, so that they may interleave.
  *
- * @param callable function that returns an observable for each item emitted by the source observable. 
+ * @param callable function that returns an observable for each item emitted by the source observable.
  * @warning #include <rpp/operators/flat_map.hpp>
  *
  * @ingroup transforming_operators

diff --git a/src/rpp/rpp/operators/last.hpp b/src/rpp/rpp/operators/last.hpp
@@ -15,7 +15,6 @@
 #include <rpp/defs.hpp>
 #include <rpp/operators/details/strategy.hpp>
 
-#include <cstddef>
 #include <optional>
 
 namespace rpp::operators::details

diff --git a/src/rpp/rpp/operators/map.hpp b/src/rpp/rpp/operators/map.hpp
@@ -15,7 +15,6 @@
 #include <rpp/defs.hpp>
 #include <rpp/operators/details/strategy.hpp>
 
-#include <cstddef>
 #include <type_traits>
 
 namespace rpp::operators::details

diff --git a/src/rpp/rpp/operators/merge.hpp b/src/rpp/rpp/operators/merge.hpp
@@ -20,8 +20,6 @@
 #include <rpp/utils/tuple.hpp>
 
 #include <atomic>
-#include <cstddef>
-#include <mutex>
 
 namespace rpp::operators::details
 {

diff --git a/src/rpp/rpp/operators/repeat.hpp b/src/rpp/rpp/operators/repeat.hpp
@@ -16,7 +16,6 @@
 #include <rpp/utils/utils.hpp>
 
 #include <cstddef>
-#include <type_traits>
 
 namespace rpp::operators::details
 {

diff --git a/src/rpp/rpp/operators/scan.hpp b/src/rpp/rpp/operators/scan.hpp
@@ -15,10 +15,8 @@
 #include <rpp/defs.hpp>
 #include <rpp/operators/details/strategy.hpp>
 
-#include "rpp/utils/constraints.hpp"
-#include "rpp/utils/utils.hpp"
+#include <rpp/utils/utils.hpp>
 
-#include <cstddef>
 #include <optional>
 
 namespace rpp::operators::details

diff --git a/src/rpp/rpp/operators/with_latest_from.hpp b/src/rpp/rpp/operators/with_latest_from.hpp
@@ -19,7 +19,6 @@
 #include <rpp/schedulers/current_thread.hpp>
 
 #include <memory>
-#include <tuple>
 
 namespace rpp::operators::details
 {

diff --git a/src/rpp/rpp/schedulers/current_thread.hpp b/src/rpp/rpp/schedulers/current_thread.hpp
@@ -17,8 +17,6 @@
 #include <rpp/schedulers/details/worker.hpp>
 #include <rpp/utils/functors.hpp>
 
-#include <thread>
-
 namespace rpp::schedulers
 {
 /**
@@ -34,7 +32,7 @@ namespace rpp::schedulers
  * worker.schedule([&worker](const auto& handler)
  * {
  *     std::cout << "Task 1 starts" << std::endl;
- * 
+ *
  *     worker.schedule([&worker](const auto& handler)
  *     {
  *         std::cout << "Task 2 starts" << std::endl;
@@ -46,13 +44,13 @@ namespace rpp::schedulers
  *         std::cout << "Task 2 ends" << std::endl;
  *         return rpp::schedulers::optional_delay_from_now{};
  *     }, handler);
- * 
+ *
  *     worker.schedule([](const auto&)
  *     {
  *         std::cout << "Task 3" << std::endl;
  *         return rpp::schedulers::optional_delay_from_now{};
  *     }, handler);
- * 
+ *
  *     std::cout << "Task 1 ends" << std::endl;
  *     return rpp::schedulers::optional_delay_from_now{};
  * }, handler);
@@ -64,20 +62,20 @@ namespace rpp::schedulers
  * - "Task 2 ends"
  * - "Task 3"
  * - "Task 4"
- * 
+ *
  * @par How to use it properly?
  * To have any visible impact you need to use it at least **twice** during same observable. For example, `rpp::source::just` source uses it as default scheduler as well as `rpp::operators::merge` operator (which just "owns" it during subscription).
  *
  * For example, this one
  * \code{.cpp}
- * rpp::source::just(1, 2, 3) 
- *  | rpp::operators::merge_with(rpp::source::just(4, 5, 6)) 
+ * rpp::source::just(1, 2, 3)
+ *  | rpp::operators::merge_with(rpp::source::just(4, 5, 6))
  *  | rpp::operators::subscribe([](int v) { std::cout << v << " "; });
  * \endcode
  * Procedes output `1 4 2 5 3 6` due to `merge_with` takes ownership over this scheduler during subscription, both sources schedule their first emissions into scheduler, then `merge_with` frees scheduler and it starts to proceed scheduled actions. As a result it continues interleaving of values. In case of usingg `rpp::schedulers::immediate` it would be:
  * \code{.cpp}
- * rpp::source::just(rpp::schedulers::immediate{}, 1, 2, 3) 
- *  | rpp::operators::merge_with(rpp::source::just(rpp::schedulers::immediate{}, 4, 5, 6)) 
+ * rpp::source::just(rpp::schedulers::immediate{}, 1, 2, 3)
+ *  | rpp::operators::merge_with(rpp::source::just(rpp::schedulers::immediate{}, 4, 5, 6))
  *  | rpp::operators::subscribe([](int v) { std::cout << v << " "; });
  * \endcode
  * With output `1 2 3 4 5 6`
@@ -153,7 +151,7 @@ class current_thread
                 if (!timepoint || handler.is_disposed())
                     return drain_queue(queue);
             }
-            else 
+            else
             {
                 timepoint = now() + duration;
             }

diff --git a/src/rpp/rpp/schedulers/details/queue.hpp b/src/rpp/rpp/schedulers/details/queue.hpp
@@ -22,7 +22,6 @@
 #include <memory>
 #include <mutex>
 #include <optional>
-#include <queue>
 #include <utility>
 
 namespace rpp::schedulers::details

diff --git a/src/rpp/rpp/subjects/details/base_subject.hpp b/src/rpp/rpp/subjects/details/base_subject.hpp
@@ -13,7 +13,7 @@
 
 #include <rpp/observables/observable.hpp>
 
-#include "rpp/disposables/fwd.hpp"
+#include <rpp/disposables/fwd.hpp>
 
 namespace rpp::subjects::details
 {

diff --git a/src/rpp/rpp/utils/functors.hpp b/src/rpp/rpp/utils/functors.hpp
@@ -10,7 +10,6 @@
 
 #pragma once
 
-#include <stdexcept>
 #include <tuple>
 
 namespace rpp::utils

diff --git a/src/rpp/rpp/utils/tuple.hpp b/src/rpp/rpp/utils/tuple.hpp
@@ -13,7 +13,6 @@
 #include <rpp/defs.hpp>
 #include <rpp/utils/constraints.hpp>
 
-#include <concepts>
 #include <cstddef>
 #include <utility>