diff --git a/.gitignore b/.gitignore
index b22eeb6..fe035ef 100644
--- a/.gitignore
+++ b/.gitignore
@@ -40,4 +40,5 @@ Thumbs.db
# Next.js
.next
-*.local
\ No newline at end of file
+*.local
+.vercel
diff --git a/libs/client/package.json b/libs/client/package.json
index 35d4379..b51a260 100644
--- a/libs/client/package.json
+++ b/libs/client/package.json
@@ -1,7 +1,7 @@
{
"name": "@fal-ai/serverless-client",
"description": "The fal serverless JS/TS client",
- "version": "0.9.1",
+ "version": "0.9.2",
"license": "MIT",
"repository": {
"type": "git",
diff --git a/libs/client/src/storage.ts b/libs/client/src/storage.ts
index 063a583..6b81038 100644
--- a/libs/client/src/storage.ts
+++ b/libs/client/src/storage.ts
@@ -121,6 +121,9 @@ export const storageImpl: StorageSupport = {
if (isPlainObject(value)) {
return [key, await storageImpl.transformInput(value)];
}
+ if (Array.isArray(value)) {
+ return [key, await Promise.all(value.map(storageImpl.transformInput))];
+ }
return [key, value] as KeyValuePair;
});
const results = await Promise.all(promises);
diff --git a/libs/client/src/streaming.ts b/libs/client/src/streaming.ts
index 115bc96..efe6cb0 100644
--- a/libs/client/src/streaming.ts
+++ b/libs/client/src/streaming.ts
@@ -72,7 +72,7 @@ class FalStream {
reject(error);
});
});
- this.start();
+ this.start().catch(this.handleError);
}
private start = async () => {
@@ -145,8 +145,7 @@ class FalStream {
this.emit(
'error',
new ApiError({
- message:
- 'Event stream timed out after 15 seconds with no messages.',
+ message: `Event stream timed out after ${(timeout / 1000).toFixed(0)} seconds with no messages.`,
status: 408,
})
);