Patrón de observador en lenguaje Go

Question

Este problema es bastante común: un objeto debe notificar a todos sus suscriptores cuando se produce algún evento. En C++ podemos usar boost::signals o algo más. Pero, ¿cómo hacer esto en Go language? Sería bueno ver un ejemplo de código de trabajo donde un par de objetos están suscritos a un editor y procesar notificaciones.

Gracias

Answer 1

Esto es bastante simple en Go. Usa canales Este es el tipo de cosa para la que están hechos.

type Publish struct { 
    listeners []chan *Msg 
} 

type Subscriber struct { 
    Channel chan *Msg 
} 

func (p *Publisher) Sub(c chan *Msg) { 
    p.appendListener(c) 
} 

func (p *Publisher) Pub(m *Msg) { 
    for _, c := range p.listeners { 
     c <- Msg 
    } 
} 

func (s *Subscriber) ListenOnChannel() { 
    for { 
     data := <-s.Channel 
     //Process data 
    } 
} 

func main() { 
    for _, v := range subscribers { 
     p.Sub(v.Channel) 
     go v.ListenOnChannel() 
    } 
    //Some kind of wait here 
} 

Obviamente esto no es exactamente una muestra de código de trabajo. Pero está cerca.