Commit 38f44ae0 authored by Dominik Charousset's avatar Dominik Charousset

Remove obsolete code / comments

parent 7f988bf5
......@@ -20,38 +20,11 @@ namespace caf::flow {
/// objects since the coordinator guarantees synchronous execution.
class CAF_CORE_EXPORT coordinator {
public:
// class CAF_CORE_EXPORT subscription_impl : public subscription::impl {
// public:
// friend class coordinator;
// subscription_impl(coordinator* ctx, observable_base_ptr src,
// observer_base_ptr snk)
// : ctx_(ctx), src_(std::move(src)), snk_(std::move(snk)) {
// // nop
// }
// void request(size_t n) final;
// void cancel() final;
// bool disposed() const noexcept final;
// auto* ctx() const noexcept {
// return ctx_;
// }
// private:
// coordinator* ctx_;
// observable_base_ptr src_;
// observer_base_ptr snk_;
// };
// using subscription_impl_ptr = intrusive_ptr<subscription_impl>;
friend class subscription_impl;
virtual ~coordinator();
/// Returns a factory object for new observable objects on this coordinator.
[[nodiscard]] observable_builder make_observable();
/// Increases the reference count of the coordinator.
......
......@@ -10,6 +10,7 @@
namespace caf::detail {
/// Always evaluates to `Left`.
template <class Left, class Right>
struct left_oracle {
using type = Left;
......
......@@ -17,23 +17,4 @@ observable_builder coordinator::make_observable() {
return observable_builder{this};
}
// void coordinator::subscription_impl::request(size_t n) {
// CAF_ASSERT(n != 0);
// if (src_) {
// ctx_->dispatch_request(src_.get(), snk_.get(), n);
// }
// }
//
// void coordinator::subscription_impl::cancel() {
// if (src_) {
// ctx_->dispatch_cancel(src_.get(), snk_.get());
// src_.reset();
// snk_.reset();
// }
// }
//
// bool coordinator::subscription_impl::disposed() const noexcept {
// return src_ == nullptr;
// }
} // namespace caf::flow
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment