goroutine.go

func TestStreamClient(t *testing.T) {
	const address = "127.0.0.1:8090"
	lis, err := net.Listen("tcp", address)
	if err != nil {
		log.Fatalf("failed to listen: %v", err)
	}
	defer lis.Close()
	s := grpc.NewServer()
	server := Server{}
	RegisterPeopleServer(s,&server)
	go s.Serve(lis)

	conn, err := grpc.Dial(address, grpc.WithInsecure())
	defer conn.Close()
	client := NewPeopleClient(conn)

	var wg sync.WaitGroup
	wg.Add(1)
	go func() {
		defer wg.Done()
		stream, _ := client.GetPeople(context.Background(), &EmptyMessage{})

		for i := 0; i < 1000000; i++ {
			stream.Recv()
		}
		println("Done")
	}()
	wg.Wait()