Skip to content

Commit 8efff94

Browse files
committed
Better names
1 parent 58e9a0c commit 8efff94

File tree

1 file changed

+8
-8
lines changed

1 file changed

+8
-8
lines changed

packages/web/src/db/adapters/WorkerWrappedAsyncDatabaseConnection.ts

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ export class WorkerWrappedAsyncDatabaseConnection<Config extends ResolvedWebSQLO
6060
this.notifyRemoteClosed!.abort();
6161
}
6262

63-
private withRemote<T>(inner: () => Promise<T>): Promise<T> {
63+
private withRemote<T>(workerPromise: () => Promise<T>): Promise<T> {
6464
const controller = this.notifyRemoteClosed;
6565
if (controller) {
6666
return new Promise((resolve, reject) => {
@@ -72,20 +72,20 @@ export class WorkerWrappedAsyncDatabaseConnection<Config extends ResolvedWebSQLO
7272
reject(new Error('Remote peer closed with request in flight'));
7373
}
7474

75-
function markResolved(inner: () => void) {
75+
function completePromise(action: () => void) {
7676
controller!.signal.removeEventListener('abort', handleAbort);
77-
inner();
77+
action();
7878
}
7979

8080
controller.signal.addEventListener('abort', handleAbort);
8181

82-
inner()
83-
.then((data) => markResolved(() => resolve(data)))
84-
.catch((e) => markResolved(() => reject(e)));
82+
workerPromise()
83+
.then((data) => completePromise(() => resolve(data)))
84+
.catch((e) => completePromise(() => reject(e)));
8585
});
8686
} else {
87-
// Can't close, so just return the inner promise unguarded.
88-
return inner();
87+
// Can't close, so just return the inner worker promise unguarded.
88+
return workerPromise();
8989
}
9090
}
9191

0 commit comments

Comments
 (0)