in client.go [300:307]
func (c *Connection) Receive() (*acpb.MessageBody, error) { select { case msg := <-c.messages: return msg, nil case <-c.closed: return nil, fmt.Errorf("connection closed with err: %w", c.getCloseErr()) } }