| Index: third_party/gsutil/third_party/apitools/samples/storage_sample/uploads_test.py
|
| diff --git a/third_party/gsutil/third_party/apitools/samples/storage_sample/uploads_test.py b/third_party/gsutil/third_party/apitools/samples/storage_sample/uploads_test.py
|
| index ad4416f60748a789723ae36b37006400f7035e8d..4eb5abad37d4b67a2570ce425e98f9ec37c65d1e 100644
|
| --- a/third_party/gsutil/third_party/apitools/samples/storage_sample/uploads_test.py
|
| +++ b/third_party/gsutil/third_party/apitools/samples/storage_sample/uploads_test.py
|
| @@ -103,6 +103,20 @@ class UploadsTest(unittest.TestCase):
|
| response = self.__InsertFile(filename, request=request)
|
| self.assertEqual(size, response.size)
|
|
|
| + def testStreamMedia(self):
|
| + filename = 'ten_meg_file'
|
| + size = 10 << 20
|
| + self.__ResetUpload(size, auto_transfer=False)
|
| + self.__upload.strategy = 'resumable'
|
| + self.__upload.total_size = size
|
| + request = self.__InsertRequest(filename)
|
| + initial_response = self.__client.objects.Insert(
|
| + request, upload=self.__upload)
|
| + self.assertIsNotNone(initial_response)
|
| + self.assertEqual(0, self.__buffer.tell())
|
| + self.__upload.StreamMedia()
|
| + self.assertEqual(size, self.__buffer.tell())
|
| +
|
| def testBreakAndResumeUpload(self):
|
| filename = ('ten_meg_file_' +
|
| ''.join(random.sample(string.ascii_letters, 5)))
|
|
|