Method test_open_upload_stream

test/test_gridfs_bucket.py:337–341

(self)

            self.assertEqual(10, self.db.fs.chunks.count_documents({"files_id": gin._id}))

    def test_open_upload_stream(self):
        gin = self.fs.open_upload_stream("from_stream")
        gin.write(b"from stream")
        gin.close()
        self.assertEqual(b"from stream", (self.fs.open_download_stream(gin._id)).read())

    def test_open_upload_stream_with_id(self):
        oid = ObjectId()