@@ -775,9 +775,7 @@ describe('DbConnection', () => {
775775 } )
776776 ) ;
777777
778- client
779- . subscriptionBuilder ( )
780- . subscribe ( 'SELECT * FROM all_view_pk_players' ) ;
778+ client . subscriptionBuilder ( ) . subscribe ( 'SELECT * FROM all_view_pk_players' ) ;
781779
782780 await Promise . resolve ( ) ;
783781 expect ( getLastSubscribeQueryStrings ( wsAdapter ) ) . toEqual ( [
@@ -844,12 +842,14 @@ describe('DbConnection', () => {
844842 } )
845843 ) ;
846844
847- client . subscriptionBuilder ( ) . subscribe ( t =>
848- t . view_pk_membership . rightSemijoin (
849- t . all_view_pk_players ,
850- ( membership , player ) => membership . playerId . eq ( player . id )
851- )
852- ) ;
845+ client
846+ . subscriptionBuilder ( )
847+ . subscribe ( t =>
848+ t . view_pk_membership . rightSemijoin (
849+ t . all_view_pk_players ,
850+ ( membership , player ) => membership . playerId . eq ( player . id )
851+ )
852+ ) ;
853853
854854 await Promise . resolve ( ) ;
855855 expect ( getLastSubscribeQueryStrings ( wsAdapter ) ) . toEqual ( [
@@ -921,12 +921,14 @@ describe('DbConnection', () => {
921921 } )
922922 ) ;
923923
924- client . subscriptionBuilder ( ) . subscribe ( t =>
925- t . sender_view_pk_players_a . rightSemijoin (
926- t . sender_view_pk_players_b ,
927- ( lhsView , rhsView ) => lhsView . id . eq ( rhsView . id )
928- )
929- ) ;
924+ client
925+ . subscriptionBuilder ( )
926+ . subscribe ( t =>
927+ t . sender_view_pk_players_a . rightSemijoin (
928+ t . sender_view_pk_players_b ,
929+ ( lhsView , rhsView ) => lhsView . id . eq ( rhsView . id )
930+ )
931+ ) ;
930932
931933 await Promise . resolve ( ) ;
932934 expect ( getLastSubscribeQueryStrings ( wsAdapter ) ) . toEqual ( [
0 commit comments