aclow-actor.go

package main

// Actor ... Defines an actor, that have always to have a flow to "act" and a
// key to manage the "action"
type Actor struct {
	isAvailable bool
	flow        chan int
}

func (actor *Actor) subscribe(c chan int) {
	actor.flow = c
	actor.isAvailable = false
}

func (actor *Actor) unsubscribe() {
	actor.flow = nil
	actor.isAvailable = true
}

func (actor *Actor) action() {
	if actor.flow != nil {
		actor.flow <- 123
	}
}