in rpc/triple/pb2/go-server/pkg/greeter.go [40:75]
func (s *GreeterProvider) SayHelloStream(svr api.Greeter_SayHelloStreamServer) error {
c, err := svr.Recv()
if err != nil {
return err
}
logger.Infof("Dubbo-go3 GreeterProvider recv 1 user, name = %s\n", c.Name)
c2, err := svr.Recv()
if err != nil {
return err
}
logger.Infof("Dubbo-go3 GreeterProvider recv 2 user, name = %s\n", c2.Name)
err = svr.Send(&models.User{
Name: "hello " + c.Name,
Age: 18,
ID: "123456789",
})
if err != nil {
return err
}
c3, err := svr.Recv()
if err != nil {
return err
}
logger.Infof("Dubbo-go3 GreeterProvider recv 3 user, name = %s\n", c3.Name)
err = svr.Send(&models.User{
Name: "hello " + c2.Name,
Age: 19,
ID: "123456789",
})
if err != nil {
return err
}
return nil
}