redisrpc/watch_test.go

package redisrpc

import (
	"log"
	"testing"
	// "time"
)

func Test_ReduceStock(t *testing.T) {

	ch := make(chan int)
	for i := 0; i < 100; i++ {
		go func() {
			log.Println("start")

			reply, err := ReduceStock("test_watch", "2")

			log.Println(reply)
			log.Println(err)
			log.Println("end")
		}()
	}
	<-ch
}