//~ "./brain"
pubsub "github.com/tuxychandru/pubsub"
"container/ring"
- "./r3events"
+ r3events "svn.spreadspace.org/realraum/go.svn/r3-eventbroker_zmq/r3events"
)
var last_movement int64
movement_window := ring.New(granularity+1)
events_chan := ps.Sub("movement")
+ defer ps.Unsub(events_chan, "movement")
myticker := time.NewTicker(time.Duration(gran_duration) * time.Second)
for { select {