light9 Changeset - 1f3e105a893c

Changeset - 1f3e105a893c

Parent rev.

Child rev.

[Not reviewed]

default

0 1 0

Drew Perttula - 9 years ago 2016-05-30 21:41:01
drewp@bigasterisk.com

predicate_objects support on SyncedGraph
Ignore-this: 9c2f3642e0601a9712c5c0ede8e9cc16

1 file changed with 16 insertions and 0 deletions:

light9/rdfdb/autodepgraphapi.py

0 comments (0 inline, 0 general)

light9/rdfdb/autodepgraphapi.py

➞

Show inline comments

@@ @@ -102,6 +102,11 @@ class AutoDepGraphApi(object): @@
         self._watchers.addPredObjWatcher(func, predicate, object)
         return self._graph.subjects(predicate, object)
     def predicate_objects(self, subject):
         func = self._getCurrentFunc()
         self._watchers.addSubjectWatcher(func, subject)
         return self._graph.predicate_objects(subject)
     def items(self, listUri):
         """generator. Having a chain of watchers on the results is not
         well-tested yet"""
@@ @@ -142,6 +147,7 @@ class _GraphWatchers(object): @@
         self._handlersSp = {} # (s,p): set(handlers)
         self._handlersPo = {} # (p,o): set(handlers)
         self._handlersSpo = {} # (s,p,o): set(handlers)
         self._handlersS = {} # s: set(handlers)
     def addSubjPredWatcher(self, func, s, p):
         if func is None:
@@ @@ -159,6 +165,9 @@ class _GraphWatchers(object): @@
     def addTripleWatcher(self, func, triple):
         self._handlersSpo.setdefault(triple, set()).add(func)
     def addSubjectWatcher(self, func, s):
         self._handlersS.setdefault(s, set()).add(func)
     def whoCares(self, patch):
         """what handler functions would care about the changes in this patch?
@@ @@ -187,6 +196,13 @@ class _GraphWatchers(object): @@
                 ret.update(funcs)
                 funcs.clear()
         affectedSubjs = set([s for s, p, o, c in patch.addQuads]+
                             [s for s, p, o, c in patch.delQuads])
         for subj, funcs in self._handlersS.iteritems():
             if subj in affectedSubjs:
                 ret.update(funcs)
                 funcs.clear()
         return ret
     def dependencies(self):

0 comments (0 inline, 0 general)