         return { state, store in
             if !self.subscribed {
                 let idKey = "id"
+                let refKey = "ref"
                 
                 // Additions
                 query.observe(.childAdded, with: { snapshot in

                        return
                    }
                    json[idKey] = snapshot.key
                    do {
                        let object = try ObjectType(object: json)
                        store.dispatch(ObjectAdded(object: object))

                        return
                    }
                    json[idKey] = snapshot.key
                    json[refKey] = snapshot.ref.description()
                    do {
                        let object = try ObjectType(object: json)
                        store.dispatch(ObjectRemoved(object: object))
