Disposable.cpp

//
//  Disposable.cpp
//  Jako
//
//  Created by John Zakharov on 06.08.16.
//  Copyright © 2016 Outlaw Studio. All rights reserved.
//

#include "Disposable.hpp"

#include <iostream>

using std::cout;
using std::endl;

std::mutex Mitsoko::Disposable::observersMutex;

std::vector<Mitsoko::Disposable::Observer*> Mitsoko::Disposable::observers;

Mitsoko::Disposable::Observer::~Observer(){
    Disposable::unsubscribe(this);
}

Mitsoko::Disposable::Disposable():id(generateId()){}

void Mitsoko::Disposable::dispose(){
    for(auto observer : observers) {
        const auto id = this->id;
//        cout << "observer = " << observer <<endl;
        observer->disposableDidDispose(id);
    }
}

void Mitsoko::Disposable::subscribe(Observer *observer){
    observersMutex.lock();
    observers.emplace_back(observer);
//    cout << "subscribe " << observer << ", observers count = " << observers.size() << endl;
    observersMutex.unlock();
}

void Mitsoko::Disposable::unsubscribe(Observer *observer){
    observersMutex.lock();
//    cout << "unsubscribe " << observer << ", observers count = " << observers.size() << endl;
    const auto it=std::find(observers.begin(),
                            observers.end(),
                            observer);
    if(observers.end() != it){
        observers.erase(it);
    }
    observersMutex.unlock();
}

Mitsoko::Disposable::Id Mitsoko::Disposable::generateId(){
    static Id previousId = 0;
    static std::mutex idLock;
    idLock.lock();
    const auto res = previousId++;
    idLock.unlock();
    return res;
}