# File lib/moped/node.rb, line 402
    def process(operation, &callback)
      if executing?(:pipeline)
        queue.push([ operation, callback ])
      else
        flush([[ operation, callback ]])
      end
    end