

def streams_by_params(self, template):

    def got_params(results):
        t = frozenset(template.iteritems())
        return [s for (s, params) in zip(self._streams, [r[1] for r in results]) if (t <= frozenset(params.iteritems()))]
    dl = defer.DeferredList([s.params() for s in self._streams], fireOnOneErrback=1, consumeErrors=1)
    self.addCallback(got_params)
    return dl

dataset/ETHPy150Open arkadini/twimp/twimp/server/inmemory.py IMStreamGroup.streams_by_params/VarMisuse@104/118 `dl`->`self`