File tree Expand file tree Collapse file tree 1 file changed +24
-5
lines changed
Expand file tree Collapse file tree 1 file changed +24
-5
lines changed Original file line number Diff line number Diff line change @@ -174,19 +174,31 @@ describe('events', () => {
174174
175175 it ( 're-dispatches in-flight when requested' , async ( ) => {
176176
177- await events . init ( { } as IConfig )
177+ await events . init ( {
178+ events : {
179+ maxInflight : 2 ,
180+ queueSize : 2 ,
181+ }
182+ } as IConfig )
178183
184+ const received : string [ ] = [ ] ;
179185 const doubleDispatch = new Promise < void > ( resolve => {
180- let dispatchCount = 0 ;
181- events . getEmitter ( ) . addListener ( ' event' , ( ) => {
182- if ( ++ dispatchCount === 2 ) {
186+ events . getEmitter ( ) . addListener ( 'event' , ( event : OutboundEvent ) => {
187+ received . push ( event . id )
188+ if ( received . length === 4 ) {
183189 resolve ( ) ;
184190 }
185191 } )
186192 } ) ;
187193
188194 await events . queueEvent ( {
189- id : `right` ,
195+ id : `1` ,
196+ type : 'message-received' ,
197+ message : `message` ,
198+ sender : 'peer1'
199+ } ) ;
200+ await events . queueEvent ( {
201+ id : `2` ,
190202 type : 'message-received' ,
191203 message : `message` ,
192204 sender : 'peer1'
@@ -196,6 +208,13 @@ describe('events', () => {
196208
197209 await doubleDispatch ;
198210
211+ expect ( received ) . to . deep . equal ( [
212+ '1' ,
213+ '2' ,
214+ '1' ,
215+ '2' ,
216+ ] )
217+
199218 } )
200219
201220} )
You can’t perform that action at this time.
0 commit comments