Pasted

package Observer
 
type (
    Event struct {
        Content interface{}
        Response chan<- float32
    }
    Monitor chan<- Event
    Target interface{
        Add(monitor Monitor)
        Remove(monitor Monitor) bool
    }
    repeater []Monitor
)
 
func (self *repeater) Add(m Monitor) {
    *self = append(*self, m)
}
 
func (self *repeater) Remove(m Monitor) bool {
    for i, which := range *self {
        if which == m {
            copy((*self)[i:], (*self)[i + 1:])
            return true
        }
    }
    return false
}
 
func (self *repeater) repeat(source <-chan Event) {
    for e := range source {
        for _, m := range *self {
            m <- e
        }
    }
}
 
func NewTarget(source <-chan Event) Target {
    t := &repeater{}
    go t.repeat(source)
    return &t
}