Skip to content

Commit 8b8cb16

Browse files
fix formatting
1 parent b3b5b7a commit 8b8cb16

File tree

1 file changed

+17
-4
lines changed

1 file changed

+17
-4
lines changed

packages/web/src/worker/sync/SharedSyncImplementation.ts

+17-4
Original file line numberDiff line numberDiff line change
@@ -209,7 +209,10 @@ export class SharedSyncImplementation
209209
* Adds a new client tab's message port to the list of connected ports
210210
*/
211211
addPort(port: MessagePort) {
212-
const portProvider = { port, clientProvider: Comlink.wrap<AbstractSharedSyncClientProvider>(port) };
212+
const portProvider = {
213+
port,
214+
clientProvider: Comlink.wrap<AbstractSharedSyncClientProvider>(port)
215+
};
213216
this.ports.push(portProvider);
214217

215218
// Give the newly connected client the latest status
@@ -296,7 +299,10 @@ export class SharedSyncImplementation
296299
const lastPort = this.ports[this.ports.length - 1];
297300
return new Promise(async (resolve, reject) => {
298301
const abortController = new AbortController();
299-
this.fetchCredentialsController = { controller: abortController, activePort: lastPort };
302+
this.fetchCredentialsController = {
303+
controller: abortController,
304+
activePort: lastPort
305+
};
300306

301307
abortController.signal.onabort = reject;
302308
try {
@@ -315,7 +321,10 @@ export class SharedSyncImplementation
315321

316322
return new Promise(async (resolve, reject) => {
317323
const abortController = new AbortController();
318-
this.uploadDataController = { controller: abortController, activePort: lastPort };
324+
this.uploadDataController = {
325+
controller: abortController,
326+
activePort: lastPort
327+
};
319328

320329
// Resolving will make it retry
321330
abortController.signal.onabort = () => resolve();
@@ -347,7 +356,11 @@ export class SharedSyncImplementation
347356
const locked = new LockedAsyncDatabaseAdapter({
348357
name: identifier,
349358
openConnection: async () => {
350-
return new WorkerWrappedAsyncDatabaseConnection({ remote, baseConnection: db, identifier });
359+
return new WorkerWrappedAsyncDatabaseConnection({
360+
remote,
361+
baseConnection: db,
362+
identifier
363+
});
351364
},
352365
logger: this.logger
353366
});

0 commit comments

Comments
 (0)