grpc stream use async socket send, but seem use them same buffer, the newer msg seems overwrite the underlying buffer about go-micro HOT 4 OPEN

func TestBuffer(t *testing.T) {
	wg := sync.WaitGroup{}
	defer wg.Wait()

	var ch = make(chan []byte, 128)
	wg.Add(1)
	go func() {
		defer wg.Done()

		buf := bytes.Buffer{}

		defer close(ch)

		for i := 1; i < 10; i++ {
			buf.Write([]byte(fmt.Sprintf("%v", i)))
			bs := buf.Bytes()
			buf.Reset()
			b := make([]byte, len(bs))
			copy(b, bs)
			ch <- b
		}

	}()

	wg.Add(1)

	go func() {
		defer wg.Done()
		for x := range ch {
			fmt.Printf("i:=%v\n", string(x))
		}
	}()
}


i:=1
i:=2
i:=3
i:=4
i:=5
i:=6
i:=7
i:=8
i:=9