blob: d1ccc544d67541a3156efc28f1e9fac9f595ff9d (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
|
<?php defined('SYSPATH') OR die('No direct access allowed.');
/**
* Kohana event subject. Uses the SPL observer pattern.
*
* $Id: Event_Subject.php 3769 2008-12-15 00:48:56Z zombor $
*
* @package Core
* @author Kohana Team
* @copyright (c) 2007-2008 Kohana Team
* @license http://kohanaphp.com/license.html
*/
abstract class Event_Subject implements SplSubject {
// Attached subject listeners
protected $listeners = array();
/**
* Attach an observer to the object.
*
* @chainable
* @param object Event_Observer
* @return object
*/
public function attach(SplObserver $obj)
{
if ( ! ($obj instanceof Event_Observer))
throw new Kohana_Exception('eventable.invalid_observer', get_class($obj), get_class($this));
// Add a new listener
$this->listeners[spl_object_hash($obj)] = $obj;
return $this;
}
/**
* Detach an observer from the object.
*
* @chainable
* @param object Event_Observer
* @return object
*/
public function detach(SplObserver $obj)
{
// Remove the listener
unset($this->listeners[spl_object_hash($obj)]);
return $this;
}
/**
* Notify all attached observers of a new message.
*
* @chainable
* @param mixed message string, object, or array
* @return object
*/
public function notify($message)
{
foreach ($this->listeners as $obj)
{
$obj->notify($message);
}
return $this;
}
} // End Event Subject
|
