code: func (c *Connection) watchRequests(ch *Channel) {
  	for {
  		select {
  		case req, ok := <-ch.reqChan:
  			// new request on the request channel
  			if !ok {
  				// after closing the request channel, release API channel and return
  				c.releaseAPIChannel(ch)
  				return
  			}
  			if err := c.processRequest(ch, req); err != nil {
  				sendReplyError(ch, req, err)
  			}
  		}
  	}
  }
docs: // watchRequests watches for requests on the request API channel and forwards them as messages to VPP.