 
        ServiceEquiv
        (equiv? [this other]
-         (service/equiv? source (get-inner-index other)))
+         (service/equiv? source (unwrap other)))
 
        Service
        (conflict? [this other]
-         (service/conflict? source (get-inner-index other)))
+         (service/conflict? source (unwrap other)))
        (reload! [this new-core]
          (service/reload! source new-core))
        (start! [this]

     (reify
       Object
       (equals [this other]
         (= source (get-inner-index other)))
       WrappedIndex
       (inner [this]
         source)
       Index
       (clear [this]

              integration now."
              ((:index core) event)))

; Provides an accessor for a source index
(defprotocol WrappedIndex
  (source [this]))

(defn- unwrap
  "Get the inner index of a wrapped index"
  [wrapped]
  (if (instance? riemann.core.WrappedIndex wrapped)
    (source wrapped)
    wrapped))

(defn wrap-index
