etcd-io__etcd/watcher_test.go

package main

import (
	"testing"
	"fmt"
)

func TestWatch(t *testing.T) {
	// watcher := createWatcher()
	c := make(chan Notification)
	d := make(chan Notification)
	w.add("/", c)
	go say(c)
	w.add("/prefix/", d)
	go say(d)
	s.Set("/prefix/foo", "bar")
}

func say(c chan Notification) {
	result := <-c

	if result.action != -1 {
		fmt.Println("yes")
	} else {
		fmt.Println("no")
	}

}