 
     fieldsByModelIdQuery = J._dataSessionFieldsByModelIdQuery[dataSessionId]
 
-    
+
     getMergedSubfields = (a, b) ->
         return a if b is undefined
         return b if a is undefined


    @onStop =>
        console.log "[#{dataSessionId}] PUBLISHER STOPPED"
        session.observerByQsString().forEach (qsString, observer) =>
            observer.stop()
        session.stop()

        if session.updateObserversFiber?
            console.warn "Uh oh, we were in the middle of updating observers."
            session.updateObserversFiber.reset()

        delete J._dataSessionFieldsByModelIdQuery[dataSessionId]
        delete dataSessionPublisherContexts[dataSessionId]
        delete J._dataSessions[dataSessionId]
        $$.JDataSession.remove dataSessionId

    @ready()



        session.updateObserversFiber = Fiber.current
        updateObservers.call dataSessionPublisherContexts[dataSessionId], dataSessionId
        session.updateObserversFiber = null

        jDataSession = new $$.JDataSession
            _id: dataSessionId
