golang数据流处理之函数回调

以股票市场划分为例:简单的打印A股、港美股、期货

type CallBack func(data1, data2 []byte)

func TestCallBack(t *testing.T) {
	d1 := "A-shares"
	d2 := "Hong Kong stocks"
	Stock([]byte(d1), []byte(d2), JustPrint)
	fmt.Println("[]byte data flow :", []byte(d1))
}

func Stock(d1 []byte, d2 []byte, callback CallBack) {
	fmt.Println("before call back", d1)
	callback(d1, d2)
	fmt.Println("after call back")
}
func JustPrint(data1, data2 []byte) {
	fmt.Println("Stock Market mainly included ", string(data1), "and", string(data2))
	fmt.Println("Another trading market is futures")
}