                             fieldsSetter[fieldName] = J.makeValueNotReadyObject()
                     instance._fields._forceSet fieldsSetter
 
-                    if reactivesObj?
-                        reactivesSetter = {}
-
-                        for reactiveName, reactiveSpec of modelClass.reactiveSpecs
-                            if reactiveSpec.denorm
-                                if reactiveName of reactivesObj
-                                    reactivesSetter[reactiveName] =
-                                        modelClass._getUnescapedSubdoc reactivesObj[reactiveName].val
-                                if reactivesSetter[reactiveName] is undefined
-                                    reactivesSetter[reactiveName] = J.makeValueNotReadyObject()
-
-                        instance._reactives._forceSet reactivesSetter
+                    instance._setReactives reactivesObj ? {}
 
                 removed: (id) ->
                     instance = collection._attachedInstances[id]

                    skip: options.skip
                    limit: options.limit

                if Meteor.isServer
                    qsString = J.fetching.stringifyQs querySpec

                    if J._watchedQuerySpecSet.get()?

            subDoc


    @_getUnescapedSubdoc: (subDoc) ->
        if J.util.isPlainObject subDoc
            ret = {}
            for key, value of subDoc
