Method test_threaded_writes

test/test_gridfs.py:236–248

(self)

        self.assertEqual(100 * [b"hello"], results)

    def test_threaded_writes(self):
        tasks = []
        for i in range(10):
            tasks.append(JustWrite(self.fs, 10))
            tasks[i].start()

        joinall(tasks)

        f = self.fs.get_last_version("test")
        self.assertEqual(f.read(), b"hello")

        # Should have created 100 versions of 'test' file
        self.assertEqual(100, self.db.fs.files.count_documents({"filename": "test"}))

    def test_get_last_version(self):
        one = self.fs.put(b"foo", filename="test")