@@ -147,7 +147,7 @@ test('a most basic test', function(t){
147147'xxxxxxxxxxxxxxxxxxxxx' ] ;
148148
149149r . on ( 'end' , function ( ) {
150- t . same ( reads , expect ) ;
150+ assert . strict ( reads , expect ) ;
151151t . end ( ) ;
152152} ) ;
153153
@@ -180,7 +180,7 @@ test('pipe', function(t){
180180const w = new TestWriter ( ) ;
181181
182182w . on ( 'end' , function ( received ) {
183- t . same ( received , expect ) ;
183+ assert . strict ( received , expect ) ;
184184t . end ( ) ;
185185} ) ;
186186
@@ -226,15 +226,15 @@ test('pipe', function(t){
226226t . equal ( ended0 , false ) ;
227227ended0 = true ;
228228ended ++ ;
229- t . same ( results , expect [ 0 ] ) ;
229+ assert . strict ( results , expect [ 0 ] ) ;
230230} ) ;
231231
232232w [ 1 ] . on ( 'end' , function ( results ) {
233233t . equal ( ended1 , false ) ;
234234ended1 = true ;
235235ended ++ ;
236236t . equal ( ended , 2 ) ;
237- t . same ( results , expect [ 1 ] ) ;
237+ assert . strict ( results , expect [ 1 ] ) ;
238238t . end ( ) ;
239239} ) ;
240240
@@ -261,11 +261,11 @@ test('multipipe', function(t){
261261
262262let c = 2 ;
263263w [ 0 ] . on ( 'end' , function ( received ) {
264- t . same ( received , expect , 'first' ) ;
264+ assert . strict ( received , expect , 'first' ) ;
265265if ( -- c === 0 ) t . end ( ) ;
266266} ) ;
267267w [ 1 ] . on ( 'end' , function ( received ) {
268- t . same ( received , expect , 'second' ) ;
268+ assert . strict ( received , expect , 'second' ) ;
269269if ( -- c === 0 ) t . end ( ) ;
270270} ) ;
271271
@@ -306,13 +306,13 @@ test('multipipe', function(t){
306306
307307w [ 0 ] . on ( 'end' , function ( results ) {
308308ended ++ ;
309- t . same ( results , expect [ 0 ] ) ;
309+ assert . strict ( results , expect [ 0 ] ) ;
310310} ) ;
311311
312312w [ 1 ] . on ( 'end' , function ( results ) {
313313ended ++ ;
314314t . equal ( ended , 2 ) ;
315- t . same ( results , expect [ 1 ] ) ;
315+ assert . strict ( results , expect [ 1 ] ) ;
316316t . end ( ) ;
317317} ) ;
318318
@@ -323,7 +323,7 @@ test('multipipe', function(t){
323323
324324test ( 'back pressure respected' , function ( t ) {
325325const r = new R ( { objectMode : true } ) ;
326- r . _read = common . noop ;
326+ r . _read = common . mustNotCall ( ) ;
327327let counter = 0 ;
328328r . push ( [ 'one' ] ) ;
329329r . push ( [ 'two' ] ) ;
@@ -341,7 +341,7 @@ test('back pressure respected', function(t){
341341r . pipe ( w3 ) ;
342342} ) ;
343343} ;
344- w1 . end = common . noop ;
344+ w1 . end = common . mustNotCall ( ) ;
345345
346346r . pipe ( w1 ) ;
347347
@@ -367,7 +367,7 @@ test('back pressure respected', function(t){
367367
368368return false ;
369369} ;
370- w2 . end = common . noop ;
370+ w2 . end = common . mustCall ( ) ;
371371
372372const w3 = new R ( ) ;
373373w3 . write = function ( chunk ) {
@@ -400,7 +400,7 @@ test('read(0) for ended streams', function(t){
400400const r = new R ( ) ;
401401let written = false ;
402402let ended = false ;
403- r . _read = common . noop ;
403+ r . _read = common . mustNotCall ( ) ;
404404
405405r . push ( Buffer . from ( 'foo' ) ) ;
406406r . push ( null ) ;
@@ -471,7 +471,7 @@ test('adding readable triggers data flow', function(t){
471471
472472test ( 'chainable' , function ( t ) {
473473const r = new R ( ) ;
474- r . _read = common . noop ;
474+ r . _read = common . mustCall ( ) ;
475475const r2 = r . setEncoding ( 'utf8' ) . pause ( ) . resume ( ) . pause ( ) ;
476476t . equal ( r , r2 ) ;
477477t . end ( ) ;
0 commit comments