

def write(self, grpos, flags, data):
    self._s.data.append((grpos, flags, data))
    self.notify_write_listeners(grpos, flags, data)
    return defer.succeed(None)

dataset/ETHPy150Open arkadini/twimp/twimp/server/inmemory.py IMStream.write/original