code: func (sp *ServerPeer) subscribeRecvMsg(subscription spMsgSubscription) {
  	sp.mtxSubscribers.Lock()
  	defer sp.mtxSubscribers.Unlock()
  	sp.recvSubscribers[subscription] = struct{}{}
  }
docs: // subscribeRecvMsg handles adding OnRead subscriptions to the server peer.