in client.go [243:253]
func (c *Connection) sendWithResp(req *acpb.StreamAgentMessagesRequest, channel chan *status.Status) error {
loggerPrintf("Sending message %+v", req)
select {
case <-c.closed:
return fmt.Errorf("connection closed with err: %w", c.getCloseErr())
case c.sends <- req:
}
return c.waitForResponse(req.GetMessageId(), channel)
}