@@ -141,14 +141,15 @@ export class grpcDriftClientAccountSubscriberV2 extends WebSocketDriftClientAcco
141141 async ( ) => {
142142 try {
143143 if ( this . resubOpts ?. logResubMessages ) {
144- console . log ( '[grpcDriftClientAccountSubscriberV2] perp markets subscriber unsubscribed; resubscribing' ) ;
144+ console . log (
145+ '[grpcDriftClientAccountSubscriberV2] perp markets subscriber unsubscribed; resubscribing'
146+ ) ;
145147 }
146148 await this . subscribeToPerpMarketAccounts ( ) ;
147149 } catch ( e ) {
148150 console . error ( 'Perp markets resubscribe failed:' , e ) ;
149151 }
150152 }
151-
152153 ) ;
153154 await this . perpMarketsSubscriber . subscribe (
154155 perpMarketPubkeys ,
@@ -182,7 +183,9 @@ export class grpcDriftClientAccountSubscriberV2 extends WebSocketDriftClientAcco
182183 async ( ) => {
183184 try {
184185 if ( this . resubOpts ?. logResubMessages ) {
185- console . log ( '[grpcDriftClientAccountSubscriberV2] spot markets subscriber unsubscribed; resubscribing' ) ;
186+ console . log (
187+ '[grpcDriftClientAccountSubscriberV2] spot markets subscriber unsubscribed; resubscribing'
188+ ) ;
186189 }
187190 await this . subscribeToSpotMarketAccounts ( ) ;
188191 } catch ( e ) {
@@ -249,7 +252,9 @@ export class grpcDriftClientAccountSubscriberV2 extends WebSocketDriftClientAcco
249252 async ( ) => {
250253 try {
251254 if ( this . resubOpts ?. logResubMessages ) {
252- console . log ( '[grpcDriftClientAccountSubscriberV2] oracle subscriber unsubscribed; resubscribing' ) ;
255+ console . log (
256+ '[grpcDriftClientAccountSubscriberV2] oracle subscriber unsubscribed; resubscribing'
257+ ) ;
253258 }
254259 await this . subscribeToOracles ( ) ;
255260 } catch ( e ) {
@@ -267,7 +272,6 @@ export class grpcDriftClientAccountSubscriberV2 extends WebSocketDriftClientAcco
267272 }
268273 ) ;
269274
270-
271275 return true ;
272276 }
273277
@@ -280,7 +284,7 @@ export class grpcDriftClientAccountSubscriberV2 extends WebSocketDriftClientAcco
280284 await super . unsubscribeFromOracles ( ) ;
281285 }
282286
283- override async unsubscribe ( ) : Promise < void > {
287+ override async unsubscribe ( ) : Promise < void > {
284288 if ( this . isSubscribed ) {
285289 return ;
286290 }
0 commit comments