Method run

test/asynchronous/test_gridfs_bucket.py:60–64

(self)

        self.daemon = True

    async def run(self):
        for _ in range(self.num):
            file = self.gfs.open_upload_stream("test")
            await file.write(b"hello")
            await file.close()


class JustRead(ConcurrentRunner):