

def notify_write_listeners(self, grpos, flags, data):
    for c in self._s.data_listeners:
        try:
            c(flags, flags, data)
        except:
            defer.fail()

dataset/ETHPy150Open arkadini/twimp/twimp/server/inmemory.py IMStream.notify_write_listeners/VarMisuse@33/41 `grpos`->`flags`