FM / driver

/opt/canhelp/node_modules/kysely/dist/cjs/driver/

/opt/canhelp/node_modules/kysely/dist/cjs/driver

Name	Size	Mode	Actions
connection-provider.d.ts	349	0644	edit dl rm
connection-provider.js	77	0644	edit dl rm
database-connection.d.ts	1273	0644	edit dl rm
database-connection.js	77	0644	edit dl rm
default-connection-provider.d.ts	548	0644	edit dl rm
default-connection-provider.js	570	0644	edit dl rm
driver.d.ts	2568	0644	edit dl rm
driver.js	900	0644	edit dl rm
dummy-driver.d.ts	2069	0644	edit dl rm
dummy-driver.js	2006	0644	edit dl rm
runtime-driver.d.ts	1867	0644	edit dl rm
runtime-driver.js	5879	0644	edit dl rm
single-connection-provider.d.ts	520	0644	edit dl rm
single-connection-provider.js	1011	0644	edit dl rm

Edit: /opt/canhelp/node_modules/kysely/dist/cjs/driver/single-connection-provider.js (1011B)

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.SingleConnectionProvider = void 0;
const ignoreError = () => { };
class SingleConnectionProvider {
    #connection;
    #runningPromise;
    constructor(connection) {
        this.#connection = connection;
    }
    async provideConnection(consumer) {
        while (this.#runningPromise) {
            await this.#runningPromise.catch(ignoreError);
        }
        // `#runningPromise` must be set to undefined before it's
        // resolved or rejected. Otherwise the while loop above
        // will misbehave.
        this.#runningPromise = this.#run(consumer).finally(() => {
            this.#runningPromise = undefined;
        });
        return this.#runningPromise;
    }
    // Run the runner in an async function to make sure it doesn't
    // throw synchronous errors.
    async #run(runner) {
        return await runner(this.#connection);
    }
}
exports.SingleConnectionProvider = SingleConnectionProvider;

"use strict"; Object.defineProperty(exports, "__esModule", { value: true }); exports.SingleConnectionProvider = void 0; const ignoreError = () => { }; class SingleConnectionProvider { #connection; #runningPromise; constructor(connection) { this.#connection = connection; } async provideConnection(consumer) { while (this.#runningPromise) { await this.#runningPromise.catch(ignoreError); } // `#runningPromise` must be set to undefined before it's // resolved or rejected. Otherwise the while loop above // will misbehave. this.#runningPromise = this.#run(consumer).finally(() => { this.#runningPromise = undefined; }); return this.#runningPromise; } // Run the runner in an async function to make sure it doesn't // throw synchronous errors. async #run(runner) { return await runner(this.#connection); } } exports.SingleConnectionProvider = SingleConnectionProvider;