File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed
Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -429,8 +429,8 @@ describe('pubsub', () => {
429429 const SUB_NAMES = [ generateSubName ( ) , generateSubName ( ) ] ;
430430 const SUB_DETACH_NAME = generateSubForDetach ( ) ;
431431
432- const thirty = Duration . from ( { minutes : 30 } ) ;
433- const sixty = Duration . from ( { minutes : 60 } ) ;
432+ const thirty = Duration . from ( { seconds : 30 } ) ;
433+ const sixty = Duration . from ( { seconds : 60 } ) ;
434434 const SUBSCRIPTIONS = [
435435 topic . subscription ( SUB_NAMES [ 0 ] , { minAckDeadline : thirty , maxAckDeadline : thirty } ) ,
436436 topic . subscription ( SUB_NAMES [ 1 ] , { minAckDeadline : sixty , maxAckDeadline : sixty } ) ,
@@ -660,8 +660,9 @@ describe('pubsub', () => {
660660 subscription . on ( 'error' , done ) ;
661661
662662 // eslint-disable-next-line @typescript-eslint/no-explicit-any
663- subscription . on ( 'message' , ( message : { data : any } ) => {
663+ subscription . on ( 'message' , message => {
664664 assert . deepStrictEqual ( message . data , Buffer . from ( 'hello' ) ) ;
665+ message . ack ( ) ;
665666
666667 if ( ++ messageCount === 10 ) {
667668 subscription . close ( done ) ;
You can’t perform that action at this time.
0 commit comments