in pkg/client/mock/stub_serverV2.go [178:194]
func (s *StubServerV2) CheckinV2(server proto.ElasticAgent_CheckinV2Server) error {
for {
checkin, err := chunk.RecvObserved(server)
if err != nil {
return err
}
resp := s.CheckinV2Impl(checkin)
if resp == nil {
// close connection to client
return nil
}
err = server.Send(resp)
if err != nil {
return err
}
}
}