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)
        dl.addCallback(got_params)
        return dl
dataset/ETHPy150Open arkadini/twimp/twimp/server/inmemory.py/IMStreamGroup.streams_by_params/original