@@ -306,28 +306,31 @@ export class SharedSyncImplementation
306
306
// Create a new StreamingSyncImplementation for each connect call. This is usually done is all SDKs.
307
307
return new WebStreamingSyncImplementation ( {
308
308
adapter : new SqliteBucketStorage ( this . dbAdapter ! , new Mutex ( ) , this . logger ) ,
309
- remote : new WebRemote ( {
310
- fetchCredentials : async ( ) => {
311
- const lastPort = this . ports [ this . ports . length - 1 ] ;
312
- return new Promise ( async ( resolve , reject ) => {
313
- const abortController = new AbortController ( ) ;
314
- this . fetchCredentialsController = {
315
- controller : abortController ,
316
- activePort : lastPort
317
- } ;
318
-
319
- abortController . signal . onabort = reject ;
320
- try {
321
- this . logger . log ( 'calling the last port client provider for credentials' ) ;
322
- resolve ( await lastPort . clientProvider . fetchCredentials ( ) ) ;
323
- } catch ( ex ) {
324
- reject ( ex ) ;
325
- } finally {
326
- this . fetchCredentialsController = undefined ;
327
- }
328
- } ) ;
329
- }
330
- } ) ,
309
+ remote : new WebRemote (
310
+ {
311
+ fetchCredentials : async ( ) => {
312
+ const lastPort = this . ports [ this . ports . length - 1 ] ;
313
+ return new Promise ( async ( resolve , reject ) => {
314
+ const abortController = new AbortController ( ) ;
315
+ this . fetchCredentialsController = {
316
+ controller : abortController ,
317
+ activePort : lastPort
318
+ } ;
319
+
320
+ abortController . signal . onabort = reject ;
321
+ try {
322
+ this . logger . log ( 'calling the last port client provider for credentials' ) ;
323
+ resolve ( await lastPort . clientProvider . fetchCredentials ( ) ) ;
324
+ } catch ( ex ) {
325
+ reject ( ex ) ;
326
+ } finally {
327
+ this . fetchCredentialsController = undefined ;
328
+ }
329
+ } ) ;
330
+ }
331
+ } ,
332
+ this . logger
333
+ ) ,
331
334
uploadCrud : async ( ) => {
332
335
const lastPort = this . ports [ this . ports . length - 1 ] ;
333
336
0 commit comments