jzelinskie
for err := stream.RecvMsg(msg); !errors.Is(err, io.EOF); err = stream.RecvMsg(msg) { ... }