@@ -699,8 +699,8 @@ const tsp = require('timers/promises');
699699const ret = pipeline ( async function * ( ) {
700700await Promise . resolve ( ) ;
701701yield 'hello' ;
702- } , async function * ( source ) {
703- for await ( const chunk of source ) { }
702+ } , async function * ( source ) { // eslint-disable-line require-yield
703+ for await ( const chunk of source ) { } // eslint-disable-line no-unused-vars
704704} , common . mustCall ( ( err ) => {
705705assert . strictEqual ( err , undefined ) ;
706706} ) ) ;
@@ -712,11 +712,11 @@ const tsp = require('timers/promises');
712712// AsyncFunction destination is not returned and error is
713713// propagated.
714714
715- const ret = pipeline ( async function * ( ) {
715+ const ret = pipeline ( async function * ( ) { // eslint-disable-line require-yield
716716await Promise . resolve ( ) ;
717717throw new Error ( 'kaboom' ) ;
718- } , async function * ( source ) {
719- for await ( const chunk of source ) { }
718+ } , async function * ( source ) { // eslint-disable-line require-yield
719+ for await ( const chunk of source ) { } // eslint-disable-line no-unused-vars
720720} , common . mustCall ( ( err ) => {
721721assert . strictEqual ( err . message , 'kaboom' ) ;
722722} ) ) ;
@@ -726,7 +726,7 @@ const tsp = require('timers/promises');
726726
727727{
728728const s = new PassThrough ( ) ;
729- pipeline ( async function * ( ) {
729+ pipeline ( async function * ( ) { // eslint-disable-line require-yield
730730throw new Error ( 'kaboom' ) ;
731731} , s , common . mustCall ( ( err ) => {
732732assert . strictEqual ( err . message , 'kaboom' ) ;
@@ -736,7 +736,7 @@ const tsp = require('timers/promises');
736736
737737{
738738const s = new PassThrough ( ) ;
739- pipeline ( async function * ( ) {
739+ pipeline ( async function * ( ) { // eslint-disable-line require-yield
740740throw new Error ( 'kaboom' ) ;
741741} ( ) , s , common . mustCall ( ( err ) => {
742742assert . strictEqual ( err . message , 'kaboom' ) ;
@@ -746,7 +746,7 @@ const tsp = require('timers/promises');
746746
747747{
748748const s = new PassThrough ( ) ;
749- pipeline ( function * ( ) {
749+ pipeline ( function * ( ) { // eslint-disable-line require-yield
750750throw new Error ( 'kaboom' ) ;
751751} , s , common . mustCall ( ( err , val ) => {
752752assert . strictEqual ( err . message , 'kaboom' ) ;
@@ -756,7 +756,7 @@ const tsp = require('timers/promises');
756756
757757{
758758const s = new PassThrough ( ) ;
759- pipeline ( function * ( ) {
759+ pipeline ( function * ( ) { // eslint-disable-line require-yield
760760throw new Error ( 'kaboom' ) ;
761761} ( ) , s , common . mustCall ( ( err , val ) => {
762762assert . strictEqual ( err . message , 'kaboom' ) ;
@@ -771,7 +771,7 @@ const tsp = require('timers/promises');
771771yield 'hello' ;
772772yield 'world' ;
773773} , s , async function ( source ) {
774- for await ( const chunk of source ) {
774+ for await ( const chunk of source ) { // eslint-disable-line no-unused-vars
775775throw new Error ( 'kaboom' ) ;
776776}
777777} , common . mustCall ( ( err , val ) => {
@@ -784,8 +784,8 @@ const tsp = require('timers/promises');
784784const s = new PassThrough ( ) ;
785785const ret = pipeline ( function ( ) {
786786return [ 'hello' , 'world' ] ;
787- } , s , async function * ( source ) {
788- for await ( const chunk of source ) {
787+ } , s , async function * ( source ) { // eslint-disable-line require-yield
788+ for await ( const chunk of source ) { // eslint-disable-line no-unused-vars
789789throw new Error ( 'kaboom' ) ;
790790}
791791} , common . mustCall ( ( err ) => {
@@ -1054,12 +1054,11 @@ const tsp = require('timers/promises');
10541054const ws = new Writable ( {
10551055write : common . mustNotCall ( )
10561056} ) ;
1057- pipeline ( rs , async function * ( stream ) {
1058- /* eslint no-unused-vars: off */
1059- for await ( const chunk of stream ) {
1057+ pipeline ( rs , async function * ( stream ) { // eslint-disable-line require-yield
1058+ for await ( const chunk of stream ) { // eslint-disable-line no-unused-vars
10601059throw new Error ( 'kaboom' ) ;
10611060}
1062- } , async function * ( source ) {
1061+ } , async function * ( source ) { // eslint-disable-line require-yield
10631062for await ( const chunk of source ) {
10641063res += chunk ;
10651064}
@@ -1394,7 +1393,7 @@ const tsp = require('timers/promises');
13941393const ac = new AbortController ( ) ;
13951394const signal = ac . signal ;
13961395pipelinep (
1397- async function * ( { signal } ) {
1396+ async function * ( { signal } ) { // eslint-disable-line require-yield
13981397await tsp . setTimeout ( 1e6 , signal ) ;
13991398} ,
14001399async function ( source ) {
0 commit comments