code: func (h *handler) handleMsg(msg *jsonrpcMessage) {
  	if ok := h.handleImmediate(msg); ok {
  		return
  	}
  	h.startCallProc(func(cp *callProc) {
  		answer := h.handleCallMsg(cp, msg)
  		h.addSubscriptions(cp.notifiers)
  		if answer != nil {
  			h.conn.Write(cp.ctx, answer)
  		}
  		for _, n := range cp.notifiers {
  			n.activate()
  		}
  	})
  }
docs: // handleMsg handles a single message.