Method activate

api/rpc/subscription.go:127–135

activate enables a subscription. Until a subscription is enabled all notifications are dropped. This method is called by the RPC server after the subscription ID was sent to client. This prevents notifications being send to the client before the subscription ID is send to the client.

(id ID, namespace string)

// the subscription ID was sent to client. This prevents notifications being
// send to the client before the subscription ID is send to the client.
func (n *Notifier) activate(id ID, namespace string) {
	n.subMu.Lock()
	defer n.subMu.Unlock()
	if sub, found := n.inactive[id]; found {
		sub.namespace = namespace
		n.active[id] = sub
		delete(n.inactive, id)
	}
}