@@ -133,6 +133,7 @@ describe('test resume up', function () {
133133 describe ( 'test resume up#putStream' , function ( ) {
134134 // eslint-disable-next-line no-undef
135135 it ( 'test resume up#putStream' , function ( done ) {
136+ this . timeout ( 5000 ) ;
136137 var key = 'storage_putStream_test' + Math . random ( 1000 ) ;
137138 var stream = new Readable ( ) ;
138139 var blkSize = 1024 * 1024 ;
@@ -151,9 +152,11 @@ describe('test resume up', function () {
151152 keysToDelete . push ( respBody . key ) ;
152153 done ( ) ;
153154 } ) ;
155+ setTimeout ( callback , 3000 ) ;
154156 } ) ;
155157
156158 it ( 'test resume up#putStream_v2' , function ( done ) {
159+ this . timeout ( 5000 ) ;
157160 var key = 'storage_putStream_test_v2' + Math . random ( 1000 ) ;
158161 var stream = new Readable ( ) ;
159162 var blkSize = 1024 * 1024 ;
@@ -174,11 +177,12 @@ describe('test resume up', function () {
174177 keysToDelete . push ( respBody . key ) ;
175178 done ( ) ;
176179 } ) ;
180+ setTimeout ( callback , 3000 ) ;
177181 } ) ;
178182
179183 it ( 'test resume up#putStream resume' , function ( done ) {
184+ this . timeout ( 5000 ) ;
180185 config . zone = null ;
181-
182186 var key = 'storage_putStream_resume_test' + Math . random ( 1000 ) ;
183187 var stream = new Readable ( ) ;
184188 var blkSize = 1024 * 1024 ;
@@ -209,13 +213,12 @@ describe('test resume up', function () {
209213 keysToDelete . push ( respBody . key ) ;
210214 done ( ) ;
211215 } ) ;
216+ setTimeout ( callback , 3000 ) ;
212217 } ) ;
213218
214219 it ( 'test resume up#putStream resume_v2' , function ( done ) {
220+ this . timeout ( 5000 ) ;
215221 config . zone = null ;
216-
217- var key = 'storage_putStream_resume_test_v2' + Math . random ( 1000 ) ;
218- var stream = new Readable ( ) ;
219222 var blkSize = 1024 * 1024 ;
220223 var blkCnt = [ 2 , 4 , 6 , 10 ] ;
221224 var tmpfile = path . join ( os . tmpdir ( ) , '/resume_file' ) ;
@@ -232,22 +235,25 @@ describe('test resume up', function () {
232235 } ) ;
233236 }
234237 } ;
235- for ( var i = 0 ; i < blkCnt . length ; i ++ ) {
236- for ( var j = 0 ; j < blkCnt [ i ] ; j ++ ) {
238+ blkCnt . forEach ( function ( i ) {
239+ var stream = new Readable ( ) ;
240+ for ( var j = 0 ; j < i ; j ++ ) {
237241 stream . push ( crypto . randomBytes ( blkSize ) ) ;
238242 }
239243 stream . push ( null ) ;
240- resumeUploader . putStream ( uploadToken , key , stream , blkCnt [ i ] * blkSize , putExtra ,
244+ var key = 'storage_putStream_resume_test_v2' + Math . random ( 1000 ) ;
245+ resumeUploader . putStream ( uploadToken , key , stream , i * blkSize , putExtra ,
241246 function (
242247 respErr ,
243248 respBody , respInfo ) {
244249 console . log ( respBody , respInfo ) ;
245250 should . not . exist ( respErr ) ;
246251 respBody . should . have . keys ( 'key' , 'hash' ) ;
247252 keysToDelete . push ( respBody . key ) ;
253+ done ( ) ;
248254 } ) ;
249- }
250-
255+ setTimeout ( callback , 3000 ) ;
256+ } ) ;
251257 } ) ;
252258 } ) ;
253259} ) ;
0 commit comments