hackedteam/core-symbian

#include "PubSubObserver.h"

CPubSubObserver::CPubSubObserver(MPubSubObserver& obs, TUid category, TUint key) :
    CActive(EPriorityStandard), iObserver(obs), iCategory(category), iKey(key)
    {
    // adds CPubSubObserver to the active scheduler
    CActiveScheduler::Add(this);
    }

CPubSubObserver::~CPubSubObserver()
    {
    // cancels any request still pending
    Cancel();

    // closing the handle to the property
    iProperty.Close();
    }

CPubSubObserver* CPubSubObserver::NewL(MPubSubObserver& obs, TUid category, TUint key)
    {
    // two phase construction
    CPubSubObserver* self = new (ELeave) CPubSubObserver(obs, category, key);
    CleanupStack::PushL(self);
    self->ConstructL();
    CleanupStack::Pop(self);
    return self;
    }

void CPubSubObserver::RunL()
    {
    // Issue a new Request...
    StartMonitorProperty();

    TInt val = 0;
    iProperty.Get(val);
    iObserver.PropertyChangedL(iCategory, iKey, val);
    }

void CPubSubObserver::DoCancel()
    {
    iProperty.Cancel();
    }

void CPubSubObserver::StartMonitorProperty()
    {
    if (!IsActive())
        {
        // now subscribe 
        iProperty.Subscribe(iStatus);
        SetActive();
        }
    }

void CPubSubObserver::ConstructL()
    {
    // attach to the property
    User::LeaveIfError(iProperty.Attach(iCategory, iKey, EOwnerThread));
    }