@@ -13,10 +13,12 @@ var cleanup = require('./utils/cleanup');
13
13
var isWindows = require ( './utils/is-windows' ) ;
14
14
var isDirectory = require ( './utils/is-directory-mock' ) ;
15
15
var testConstants = require ( './utils/test-constants' ) ;
16
+ var testStreams = require ( './utils/test-streams' ) ;
17
+
18
+ var join = testStreams . join ;
19
+ var mochaPump = testStreams . mochaPump ;
16
20
17
21
var from = miss . from ;
18
- var pipe = miss . pipe ;
19
- var concat = miss . concat ;
20
22
21
23
var inputBase = testConstants . inputBase ;
22
24
var outputBase = testConstants . outputBase ;
@@ -52,10 +54,10 @@ describe('.dest() with symlinks', function() {
52
54
expect ( files [ 0 ] . path ) . toEqual ( outputPath ) ;
53
55
}
54
56
55
- pipe ( [
57
+ mochaPump ( this , [
56
58
from . obj ( [ file ] ) ,
57
59
vfs . dest ( outputBase ) ,
58
- concat ( assert ) ,
60
+ join ( assert ) ,
59
61
] , done ) ;
60
62
} ) ;
61
63
@@ -76,10 +78,10 @@ describe('.dest() with symlinks', function() {
76
78
expect ( outputLink ) . toEqual ( path . normalize ( '../fixtures/test.txt' ) ) ;
77
79
}
78
80
79
- pipe ( [
81
+ mochaPump ( this , [
80
82
from . obj ( [ file ] ) ,
81
83
vfs . dest ( outputBase , { relativeSymlinks : true } ) ,
82
- concat ( assert ) ,
84
+ join ( assert ) ,
83
85
] , done ) ;
84
86
} ) ;
85
87
@@ -112,10 +114,10 @@ describe('.dest() with symlinks', function() {
112
114
expect ( lstats . isDirectory ( ) ) . toEqual ( false ) ;
113
115
}
114
116
115
- pipe ( [
117
+ mochaPump ( this , [
116
118
from . obj ( [ file ] ) ,
117
119
vfs . dest ( outputBase ) ,
118
- concat ( assert ) ,
120
+ join ( assert ) ,
119
121
] , done ) ;
120
122
} ) ;
121
123
@@ -149,10 +151,10 @@ describe('.dest() with symlinks', function() {
149
151
expect ( lstats . isDirectory ( ) ) . toEqual ( false ) ;
150
152
}
151
153
152
- pipe ( [
154
+ mochaPump ( this , [
153
155
from . obj ( [ file ] ) ,
154
156
vfs . dest ( outputBase ) ,
155
- concat ( assert ) ,
157
+ join ( assert ) ,
156
158
] , done ) ;
157
159
} ) ;
158
160
@@ -185,10 +187,10 @@ describe('.dest() with symlinks', function() {
185
187
expect ( lstats . isDirectory ( ) ) . toEqual ( false ) ;
186
188
}
187
189
188
- pipe ( [
190
+ mochaPump ( this , [
189
191
from . obj ( [ file ] ) ,
190
192
vfs . dest ( outputBase , { useJunctions : false } ) ,
191
- concat ( assert ) ,
193
+ join ( assert ) ,
192
194
] , done ) ;
193
195
} ) ;
194
196
@@ -227,10 +229,10 @@ describe('.dest() with symlinks', function() {
227
229
expect ( lstats . isDirectory ( ) ) . toEqual ( false ) ;
228
230
}
229
231
230
- pipe ( [
232
+ mochaPump ( this , [
231
233
from . obj ( [ file ] ) ,
232
234
vfs . dest ( outputBase , { useJunctions : useJunctions } ) ,
233
- concat ( assert ) ,
235
+ join ( assert ) ,
234
236
] , done ) ;
235
237
} ) ;
236
238
@@ -263,10 +265,10 @@ describe('.dest() with symlinks', function() {
263
265
expect ( lstats . isDirectory ( ) ) . toEqual ( false ) ;
264
266
}
265
267
266
- pipe ( [
268
+ mochaPump ( this , [
267
269
from . obj ( [ file ] ) ,
268
270
vfs . dest ( outputBase , { relativeSymlinks : true } ) ,
269
- concat ( assert ) ,
271
+ join ( assert ) ,
270
272
] , done ) ;
271
273
} ) ;
272
274
@@ -300,10 +302,10 @@ describe('.dest() with symlinks', function() {
300
302
expect ( lstats . isDirectory ( ) ) . toEqual ( false ) ;
301
303
}
302
304
303
- pipe ( [
305
+ mochaPump ( this , [
304
306
from . obj ( [ file ] ) ,
305
307
vfs . dest ( outputBase , { useJunctions : true , relativeSymlinks : true } ) ,
306
- concat ( assert ) ,
308
+ join ( assert ) ,
307
309
] , done ) ;
308
310
} ) ;
309
311
@@ -329,11 +331,11 @@ describe('.dest() with symlinks', function() {
329
331
expect ( outputLink ) . toEqual ( path . normalize ( '../fixtures/test.txt' ) ) ;
330
332
}
331
333
332
- pipe ( [
334
+ mochaPump ( this , [
333
335
from . obj ( [ file ] ) ,
334
336
// The useJunctions option is ignored when file is not a directory
335
337
vfs . dest ( outputBase , { useJunctions : true , relativeSymlinks : true } ) ,
336
- concat ( assert ) ,
338
+ join ( assert ) ,
337
339
] , done ) ;
338
340
} ) ;
339
341
@@ -369,10 +371,10 @@ describe('.dest() with symlinks', function() {
369
371
expect ( lstats . isDirectory ( ) ) . toEqual ( false ) ;
370
372
}
371
373
372
- pipe ( [
374
+ mochaPump ( this , [
373
375
from . obj ( [ file ] ) ,
374
376
vfs . dest ( outputBase , { useJunctions : false , relativeSymlinks : true } ) ,
375
- concat ( assert ) ,
377
+ join ( assert ) ,
376
378
] , done ) ;
377
379
} ) ;
378
380
@@ -399,10 +401,10 @@ describe('.dest() with symlinks', function() {
399
401
fs . mkdirSync ( outputBase ) ;
400
402
fs . writeFileSync ( outputPath , existingContents ) ;
401
403
402
- pipe ( [
404
+ mochaPump ( this , [
403
405
from . obj ( [ file ] ) ,
404
406
vfs . dest ( outputBase , { overwrite : false } ) ,
405
- concat ( assert ) ,
407
+ join ( assert ) ,
406
408
] , done ) ;
407
409
} ) ;
408
410
@@ -430,10 +432,10 @@ describe('.dest() with symlinks', function() {
430
432
fs . mkdirSync ( outputBase ) ;
431
433
fs . writeFileSync ( outputPath , existingContents ) ;
432
434
433
- pipe ( [
435
+ mochaPump ( this , [
434
436
from . obj ( [ file ] ) ,
435
437
vfs . dest ( outputBase , { overwrite : true } ) ,
436
- concat ( assert ) ,
438
+ join ( assert ) ,
437
439
] , done ) ;
438
440
} ) ;
439
441
@@ -465,10 +467,10 @@ describe('.dest() with symlinks', function() {
465
467
fs . mkdirSync ( outputBase ) ;
466
468
fs . writeFileSync ( outputPath , existingContents ) ;
467
469
468
- pipe ( [
470
+ mochaPump ( this , [
469
471
from . obj ( [ file ] ) ,
470
472
vfs . dest ( outputBase , { overwrite : overwrite } ) ,
471
- concat ( assert ) ,
473
+ join ( assert ) ,
472
474
] , done ) ;
473
475
} ) ;
474
476
@@ -500,10 +502,10 @@ describe('.dest() with symlinks', function() {
500
502
fs . mkdirSync ( outputBase ) ;
501
503
fs . writeFileSync ( outputPath , existingContents ) ;
502
504
503
- pipe ( [
505
+ mochaPump ( this , [
504
506
from . obj ( [ file ] ) ,
505
507
vfs . dest ( outputBase , { overwrite : overwrite } ) ,
506
- concat ( assert ) ,
508
+ join ( assert ) ,
507
509
] , done ) ;
508
510
} ) ;
509
511
} ) ;
0 commit comments