

def unsubscribe(self, subscription):
    dl = defer.DeferredList([stream.unsubscribe(sub) for (stream, sub) in subscription], fireOnOneErrback=1, consumeErrors=1)
    dl.addCallback((lambda results: None))
    return dl

dataset/ETHPy150Open arkadini/twimp/twimp/server/inmemory.py IMStreamGroup.unsubscribe/original