Observable.php

<?php

class Observable {
  var $_observers=Array();
  
  function Observable() {
  
  }
  
  function attach($event, &$obj)
  {
    if (!is_object($obj)) {
        return false;
    }
    $obj->_observerId = uniqid(rand());
    $this->_observers[$event][$obj->_observerId] = &$obj;
  }
  
  function attach_all(&$obj)
  {
    if (!is_object($obj)) {
        return false;
    }
    $obj->_observerId = uniqid(rand());
    $this->_observers['all'][$obj->_observerId] = &$obj;
  }
  
  function dettach(&$obj)
  {
        if (isset($this->_observers[$obj->_observerId])) {
        unset($this->_observers[$obj->_observerId]);
    }
  }
  
  function notify_all($event, $msg)
  {
        //reset($this->_observers[$event]);
        if(isset($this->_observers[$event])) {
        foreach ($this->_observers[$event] as $observer) {
                $observer->notify($event,$msg);
        }
    }
        if(isset($this->_observers['all'])) {
        foreach ($this->_observers['all'] as $observer) {
                $observer->notify($event,$msg);
        }
    }
    
  } 

}
?>

---