func stream()

in rpc/triple/pb/dubbogo-grpc/grpc-client/main.go [56:84]

• 24 lines of code
• 5 McCabe index (conditional complexity)

func stream(c pb.GreeterClient) {
	fmt.Printf(">>>>> gRPC-go client is about to call SayHelloStream\n")

	clientStream, err := c.SayHelloStream(context.Background())
	if err != nil {
		panic(err)
	}

	BigDataReq := &pb.HelloRequest{
		Name: "Laurence",
	}

	for i := 0; i < 2; i++ {
		_ = clientStream.Send(BigDataReq)
	}
	user1, err := clientStream.Recv()
	if err != nil {
		panic(err)
	}
	fmt.Printf("get 1 received user = %+v\n", user1)

	_ = clientStream.Send(BigDataReq)

	user2, err := clientStream.Recv()
	if err != nil {
		panic(err)
	}
	fmt.Printf("get 2 received user = %+v\n", user2)
}