             # Run notifications
             notifications = []
             if (notification = op.notification?())
+                # Extend by subscriptions node notifications
+                # TODO: only if authoritative!
+                notification = notification.concat
+                    generateSubscriptionsNotifications(notification)
+                # Call Notify operation grouped by node
+                # (looks up subscribers by node)
                 for own node, notifications of groupByNode(notification)
                     notification.node = node
                     new Notify(router, notification).run (err) ->

            result[update.node] = []
        result[update.node].push update
    result

# and authorization form query
#
# The RSM handling here respects only a <max/> value.
#
# Doesn't care about about subscriptions nodes.
class ReplayArchive extends ModelOperation
    transaction: (t, cb) ->
        max = @req.rsm?.max or 50
