Skip to content

Commit 728072a

Browse files
committed
updated errorf
1 parent 8b424c3 commit 728072a

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

main.go

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -120,14 +120,13 @@ func (s *server) Plus(ctx context.Context, in *pb.PlusRequest) (*pb.PlusReply, e
120120
func (s *server) SayHelloMultiReply(req *pb.HelloRequest, stream pb.Greeter_SayHelloMultiReplyServer) error {
121121
log.Printf("Received server side stream req: %v\n", req)
122122

123-
// Say Hello 5 time with sleep of 1 sec.
123+
// Say Hello 5 times.
124124
for i := 0; i < 5; i++ {
125125
if err := stream.Send(&pb.HelloReply{
126126
Message: fmt.Sprintf("Hello %s", req.Name),
127127
}); err != nil {
128128
return status.Errorf(codes.Unavailable, "Unable to stream request back to client: %v", err)
129129
}
130-
time.Sleep(time.Second)
131130
}
132131
return nil
133132
}
@@ -165,7 +164,7 @@ func (s *server) SayHelloMulti(stream pb.Greeter_SayHelloMultiServer) error {
165164
time.Sleep(500 * time.Millisecond)
166165

167166
if err := stream.Send(&pb.HelloReply{Message: fmt.Sprintf("Hello %s", req.Name)}); err != nil {
168-
return status.Errorf(codes.Unknown, "Failed to stream response back to client: ", err)
167+
return status.Errorf(codes.Unknown, "Failed to stream response back to client: %v", err)
169168
}
170169
}
171170
}

0 commit comments

Comments
 (0)