11import { EventEmitter } from 'events'
22import { expect } from 'chai'
3- import { createSpy , getSpyCalls } from 'spyfn '
3+ import fn from 'test-fn '
44import { waitTimePromise as wait } from '@psxcode/wait'
55import onceAllPromiseExReject from '../src/once-all-ex-promise-reject'
66import listenerCount from './listener-count'
77
88describe ( '[ onceAllExPromiseReject ]' , ( ) => {
99 it ( 'single ee' , async ( ) => {
1010 const ee = new EventEmitter ( )
11- const resolveSpy = createSpy ( ( ) => { } )
12- const rejectSpy = createSpy ( ( ) => { } )
11+ const resolveSpy = fn ( )
12+ const rejectSpy = fn ( )
1313
1414 /* subscribe */
1515 onceAllPromiseExReject ( [ 'error' ] , [ 'event1' , 'event2' , 'event3' ] ) ( ee )
@@ -25,21 +25,21 @@ describe('[ onceAllExPromiseReject ]', () => {
2525 /* wait for ee to fire */
2626 await wait ( 0 )
2727
28- expect ( getSpyCalls ( resolveSpy ) ) . deep . eq ( [
28+ expect ( resolveSpy . calls ) . deep . eq ( [
2929 [
3030 [ { value : 'e1' , event : 'event1' , index : 0 , emitter : ee , emitterIndex : 0 } ] ,
3131 ] ,
3232 ] )
33- expect ( getSpyCalls ( rejectSpy ) ) . deep . eq ( [ ] )
33+ expect ( rejectSpy . calls ) . deep . eq ( [ ] )
3434 expect ( listenerCount ( ee ) ) . eq ( 0 )
3535 } )
3636
3737 it ( 'multiple ees' , async ( ) => {
3838 const ee0 = new EventEmitter ( )
3939 const ee1 = new EventEmitter ( )
4040 const ee2 = new EventEmitter ( )
41- const resolveSpy = createSpy ( ( ) => { } )
42- const rejectSpy = createSpy ( ( ) => { } )
41+ const resolveSpy = fn ( )
42+ const rejectSpy = fn ( )
4343
4444 /* subscribe */
4545 onceAllPromiseExReject ( [ 'error' ] , [ 'event1' , 'event2' , 'event3' ] ) ( ee0 , ee1 , ee2 ) . then ( resolveSpy , rejectSpy )
@@ -54,7 +54,7 @@ describe('[ onceAllExPromiseReject ]', () => {
5454 /* wait for ee to fire */
5555 await wait ( 0 )
5656
57- expect ( getSpyCalls ( resolveSpy ) ) . deep . eq ( [
57+ expect ( resolveSpy . calls ) . deep . eq ( [
5858 [
5959 [
6060 { value : 'e3' , event : 'event3' , index : 0 , emitter : ee0 , emitterIndex : 0 } ,
@@ -63,14 +63,14 @@ describe('[ onceAllExPromiseReject ]', () => {
6363 ] ,
6464 ] ,
6565 ] )
66- expect ( getSpyCalls ( rejectSpy ) ) . deep . eq ( [ ] )
66+ expect ( rejectSpy . calls ) . deep . eq ( [ ] )
6767 expect ( listenerCount ( ee0 , ee1 , ee2 ) ) . eq ( 0 )
6868 } )
6969
7070 it ( 'single ee error' , async ( ) => {
7171 const ee = new EventEmitter ( )
72- const resolveSpy = createSpy ( ( ) => { } )
73- const rejectSpy = createSpy ( ( ) => { } )
72+ const resolveSpy = fn ( )
73+ const rejectSpy = fn ( )
7474
7575 /* subscribe */
7676 onceAllPromiseExReject ( [ 'error' ] , [ 'event1' , 'event2' ] ) ( ee ) . then ( resolveSpy , rejectSpy )
@@ -83,8 +83,8 @@ describe('[ onceAllExPromiseReject ]', () => {
8383 /* wait for ee to fire */
8484 await wait ( 0 )
8585
86- expect ( getSpyCalls ( resolveSpy ) ) . deep . eq ( [ ] )
87- expect ( getSpyCalls ( rejectSpy ) ) . deep . eq ( [
86+ expect ( resolveSpy . calls ) . deep . eq ( [ ] )
87+ expect ( rejectSpy . calls ) . deep . eq ( [
8888 [
8989 { value : 'err' , event : 'error' , index : 0 , emitter : ee , emitterIndex : 0 } ,
9090 ] ,
0 commit comments