             at = i
           if ref
             sub.changed(@id, o._id, _.object([["_#{@id}_i", i + 1]]))
-          sub.changed(@id, id, _.object([["_#{@id}_i", i]]))
-        #Change in @PaginatedCollection
+          
+        sub.changed(@id, id, _.object([["_#{@id}_i", i]]))
       ).bind @, sub
+      
       changed: ((sub, id, fields) ->
         try
-          #Change in @PaginatedCollection
           sub.changed @id, id, fields
         catch e
       ).bind @, sub
+      
       removed: ((sub, id) ->
         try
-          #Remove from @PaginatedCollection
           sub.removed @id, id
         catch e
       ).bind @, sub
+    
+    # Add the documents from this query 
+    
     n = 0
     c.forEach ((doc, index, cursor) ->
       n++
       doc["_#{@id}_p"] = page
       doc["_#{@id}_i"] = index
-      #Initial add to @PaginatedCollection
       sub.added @id, doc._id, doc
     ).bind @
+    
     init = false
     sub.onStop ->
       handle.stop()

          id = doc._id
          delete doc._id
          unless init
            #Add to @PaginatedCollection
            sub.added(@id, id, doc)
            (@Collection.find get "filters",
              sort: get "sort"

      return  if page is NaN
      total = @sess "totalPages"
      return @ready true  if total is 0
      
      # Request data for the page
      
      if page <= total
        @requestPage page
        @queueNeighbors page
        @checkQueue()
      
      # Return the content of this page 
      #
      # The contents will be updated (as will the page) as data arrives from the server
      
      if @infinite
        n = @PaginatedCollection.find({},
          fields: @fields
