                                     @_change_feeds[changefeed_id] = [feed]
                                     changefeed_state = 'initializing'
                                     feed.each (err, x) =>
-                                        if x?.state?
-                                            changefeed_state = x.state
-                                        if not err and changefeed_state != 'ready'
-                                            # still producing initial documents (happens with some queries)
-                                            return
+                                        #if x?.state?
+                                        #    changefeed_state = x.state
+                                        #if not err and changefeed_state != 'ready'
+                                        #    # still producing initial documents (happens with some queries)
+                                        #    return
                                         winston.debug("FEED #{changefeed_id} -- saw a change! #{misc.to_json([err,x])}")
                                         if not err
                                             @_query_set_defaults(x.new_val, opts.table, misc.keys(opts.query))

                                        # I think that plucking only the project_id should work, but it actually doesn't
                                        # (I don't understand why yet).
                                        # Changeeds are tricky!
                                        @table('projects').getAll(opts.account_id, index:'users').pluck('users').changes(includeStates: true).run (err, feed) =>
                                            killfeed = feed; cb(err)
                                    else
                                        cb()
                    else if x == "collaborators"

                                            changefeed_cb("killfeed")
                                            # Saw activity -- cancel the feeds (both the main one and the killfeed)
                                            @user_query_cancel_changefeed(id: changefeed_id)
                            db_query_no_opts.changes(includeStates: false).run(includeInitialVals: false, do_feed)
        ], (err) =>
            #if err
            #    dbg("error: #{misc.to_json(err)}")
