Add concurrency limits

packages/libsql-client/package.json

@@ -105,7 +105,8 @@
         "@libsql/core": "^0.6.2",
         "@libsql/hrana-client": "^0.6.0",
         "js-base64": "^3.7.5",
-        "libsql": "^0.3.10"
+        "libsql": "^0.3.10",
+        "promise-limit": "^2.7.0"
     },
     "devDependencies": {
         "@types/jest": "^29.2.5",

packages/libsql-client/src/http.ts

@@ -24,9 +24,12 @@ import {
     getIsSchemaDatabase,
     waitForLastMigrationJobToFinish,
 } from "./migrations.js";
+import promiseLimit from "promise-limit";
 
 export * from "@libsql/core/api";
 
+const limit = promiseLimit<ResultSet>(1);
+
 export function createClient(config: Config): Client {
     return _createClient(expandConfig(config, true));
 }
@@ -99,33 +102,35 @@ export class HttpClient implements Client {
     }
 
     async execute(stmt: InStatement): Promise<ResultSet> {
-        try {
-            const isSchemaDatabasePromise = this.getIsSchemaDatabase();
-            const hranaStmt = stmtToHrana(stmt);
-
-            // Pipeline all operations, so `hrana.HttpClient` can open the stream, execute the statement and
-            // close the stream in a single HTTP request.
-            let rowsPromise: Promise<hrana.RowsResult>;
-            const stream = this.#client.openStream();
+        return limit(async () => {
             try {
-                rowsPromise = stream.query(hranaStmt);
-            } finally {
-                stream.closeGracefully();
-            }
-
-            const rowsResult = await rowsPromise;
-            const isSchemaDatabase = await isSchemaDatabasePromise;
-            if (isSchemaDatabase) {
-                await waitForLastMigrationJobToFinish({
-                    authToken: this.#authToken,
-                    baseUrl: this.#url.origin,
-                });
+                const isSchemaDatabasePromise = this.getIsSchemaDatabase();
+                const hranaStmt = stmtToHrana(stmt);
+
+                // Pipeline all operations, so `hrana.HttpClient` can open the stream, execute the statement and
+                // close the stream in a single HTTP request.
+                let rowsPromise: Promise<hrana.RowsResult>;
+                const stream = this.#client.openStream();
+                try {
+                    rowsPromise = stream.query(hranaStmt);
+                } finally {
+                    stream.closeGracefully();
+                }
+
+                const rowsResult = await rowsPromise;
+                const isSchemaDatabase = await isSchemaDatabasePromise;
+                if (isSchemaDatabase) {
+                    await waitForLastMigrationJobToFinish({
+                        authToken: this.#authToken,
+                        baseUrl: this.#url.origin,
+                    });
+                }
+
+                return resultSetFromHrana(rowsResult);
+            } catch (e) {
+                throw mapHranaError(e);
             }
-
-            return resultSetFromHrana(rowsResult);
-        } catch (e) {
-            throw mapHranaError(e);
-        }
+        });
     }
 
     async batch(