2017
[folly.git] / folly / experimental / observer / Observable.h
1 /*
2  * Copyright 2017 Facebook, Inc.
3  *
4  * Licensed under the Apache License, Version 2.0 (the "License");
5  * you may not use this file except in compliance with the License.
6  * You may obtain a copy of the License at
7  *
8  *   http://www.apache.org/licenses/LICENSE-2.0
9  *
10  * Unless required by applicable law or agreed to in writing, software
11  * distributed under the License is distributed on an "AS IS" BASIS,
12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13  * See the License for the specific language governing permissions and
14  * limitations under the License.
15  */
16 #pragma once
17
18 #include <folly/experimental/observer/Observer.h>
19
20 namespace folly {
21 namespace observer {
22
23 template <typename Observable>
24 struct ObservableTraits {
25   using element_type =
26       typename std::remove_reference<Observable>::type::element_type;
27
28   static std::shared_ptr<const element_type> get(Observable& observable) {
29     return observable.get();
30   }
31
32   template <typename F>
33   static void subscribe(Observable& observable, F&& callback) {
34     observable.subscribe(std::forward<F>(callback));
35   }
36
37   static void unsubscribe(Observable& observable) {
38     observable.unsubscribe();
39   }
40 };
41
42 template <typename Observable, typename Traits = ObservableTraits<Observable>>
43 class ObserverCreator {
44  public:
45   using T = typename Traits::element_type;
46
47   template <typename... Args>
48   explicit ObserverCreator(Args&&... args);
49
50   Observer<T> getObserver() &&;
51
52  private:
53   class Context;
54
55   std::shared_ptr<Context> context_;
56 };
57 }
58 }
59
60 #include <folly/experimental/observer/Observable-inl.h>