Lint fixes for yarpl (#420)

Author: alexmalyshev

experimental/yarpl/include/yarpl/Observable.h

@@ -65,7 +65,7 @@ class Observable : public virtual Refcounted {
   template <typename OnSubscribe>
   class FromPublisherOperator : public Observable<T> {
    public:
-    FromPublisherOperator(OnSubscribe&& function)
+    explicit FromPublisherOperator(OnSubscribe&& function)
         : function_(std::move(function)) {}
 
     void subscribe(Reference<Observer<T>> subscriber) override {

experimental/yarpl/include/yarpl/Refcounted.h

@@ -81,7 +81,7 @@ class Reference {
     inc();
   }
 
-  Reference(Reference&& other) : pointer_(other.pointer_) {
+  Reference(Reference&& other) noexcept : pointer_(other.pointer_) {
     other.pointer_ = nullptr;
   }
 

experimental/yarpl/include/yarpl/flowable/FlowableOperator.h

@@ -247,7 +247,7 @@ class SubscribeOnOperator : public FlowableOperator<T, T> {
 template <typename T, typename OnSubscribe>
 class FromPublisherOperator : public Flowable<T> {
  public:
-  FromPublisherOperator(OnSubscribe&& function)
+  explicit FromPublisherOperator(OnSubscribe&& function)
       : function_(std::move(function)) {}
 
   void subscribe(Reference<Subscriber<T>> subscriber) override {

experimental/yarpl/include/yarpl/observable/ObservableOperator.h

@@ -224,7 +224,7 @@ class SubscribeOnOperator : public ObservableOperator<T, T> {
 template <typename T, typename OnSubscribe>
 class FromPublisherOperator : public Observable<T> {
  public:
-  FromPublisherOperator(OnSubscribe&& function)
+  explicit FromPublisherOperator(OnSubscribe&& function)
       : function_(std::move(function)) {}
 
   void subscribe(Reference<Observer<T>> subscriber) override {

experimental/yarpl/include/yarpl/observable/Observers.h

@@ -73,7 +73,7 @@ class Observers {
   template <typename T, typename Next>
   class Base : public Observer<T> {
    public:
-    Base(Next&& next)
+    explicit Base(Next&& next)
         : next_(std::forward<Next>(next)) {}
 
     void onNext(T value) override {

experimental/yarpl/test/Observable_test.cpp

@@ -383,7 +383,8 @@ TEST(Observable, DISABLED_SimpleTake) {
 }
 
 TEST(Observable, Error) {
-  auto observable = Observables::error<int>(std::runtime_error("something broke!"));
+  auto observable =
+      Observables::error<int>(std::runtime_error("something broke!"));
   auto collector = make_ref<CollectingObserver<int>>();
   observable->subscribe(collector);