@@ -399,7 +399,7 @@ describe('Firebase Functions > Stream', () => {
399
399
expect ( ( error as FunctionsError ) . code ) . to . equal ( `${ FUNCTIONS_TYPE } /internal` ) ;
400
400
}
401
401
expect ( errorThrown ) . to . be . true ;
402
- await expectError ( streamResult . data , "internal" , "Internal " ) ;
402
+ await expectError ( streamResult . data , "internal" , "internal " ) ;
403
403
} ) ;
404
404
405
405
it ( 'handles server-side errors' , async ( ) => {
@@ -524,7 +524,7 @@ describe('Firebase Functions > Stream', () => {
524
524
expect ( ( error as FunctionsError ) . code ) . to . equal ( `${ FUNCTIONS_TYPE } /cancelled` ) ;
525
525
}
526
526
expect ( errorThrown ) . to . be . true ;
527
- await expectError ( streamResult . data , "cancelled" , "Request was cancelled" ) ;
527
+ await expectError ( streamResult . data , "cancelled" , "Request was cancelled. " ) ;
528
528
} ) ;
529
529
530
530
it ( 'aborts during streaming' , async ( ) => {
@@ -566,7 +566,7 @@ describe('Firebase Functions > Stream', () => {
566
566
expect ( ( error as FunctionsError ) . code ) . to . equal ( `${ FUNCTIONS_TYPE } /cancelled` ) ;
567
567
}
568
568
expect ( messages ) . to . deep . equal ( [ 'First' ] ) ;
569
- await expectError ( streamResult . data , "cancelled" , "Request was cancelled" ) ;
569
+ await expectError ( streamResult . data , "cancelled" , "Request was cancelled. " ) ;
570
570
} ) ;
571
571
572
572
it ( 'fails immediately with pre-aborted signal' , async ( ) => {
@@ -591,7 +591,7 @@ describe('Firebase Functions > Stream', () => {
591
591
expect ( ( error as FunctionsError ) . code ) . to . equal ( `${ FUNCTIONS_TYPE } /cancelled` ) ;
592
592
}
593
593
expect ( errorThrown ) . to . be . true ;
594
- await expectError ( streamResult . data , "cancelled" , "Request was cancelled" ) ;
594
+ await expectError ( streamResult . data , "cancelled" , "Request was cancelled. " ) ;
595
595
} ) ;
596
596
597
597
it ( 'properly handles AbortSignal.timeout()' , async ( ) => {
@@ -623,6 +623,6 @@ describe('Firebase Functions > Stream', () => {
623
623
} catch ( error ) {
624
624
expect ( ( error as FunctionsError ) . code ) . to . equal ( `${ FUNCTIONS_TYPE } /cancelled` ) ;
625
625
}
626
- await expectError ( streamResult . data , "cancelled" , "Request was cancelled" ) ;
626
+ await expectError ( streamResult . data , "cancelled" , "Request was cancelled. " ) ;
627
627
} ) ;
628
628
} ) ;
0 commit comments