async def corofunc(**local_args):
            nonlocal called
            assert local_args == args
            called += 1
def buffer_updated(self, nbytes):
        self.transport.write(self.buffer[:nbytes])