Types: replacing ReadableStream and WritableStream

types/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/types",
-  "version": "0.3.3",
+  "version": "0.3.4",
   "description": "Pipedream TypeScript types",
   "keywords": [
     "pipedream",

types/src/index.ts

@@ -1,3 +1,5 @@
+import { Readable, Writable } from "stream";
+
 /* eslint-disable @typescript-eslint/no-explicit-any */
 export type JSONValue =
   | string
@@ -69,7 +71,7 @@
   /**
    * Http Body
    */
-  body: string | Buffer | ReadableStream;
+  body: string | Buffer | Readable;
   /**
    * If true, issue the response when the promise returned is resolved, otherwise issue
    * the response at the end of the workflow execution
@@ -114,13 +116,13 @@
 
 export interface IFile {
   delete(): Promise<void>;
-  createReadStream(): Promise<ReadableStream>;
-  createWriteStream(contentType?: string, contentLength?: number): Promise<WritableStream>;
+  createReadStream(): Promise<Readable>;
+  createWriteStream(contentType?: string, contentLength?: number): Promise<Writable>;
   toEncodedString(encoding?: string, start?: number, end?: number): Promise<string>;
   toUrl(): Promise<string>;
   toFile(localFilePath: string): Promise<void>;
   toBuffer(): Promise<Buffer>;
-  fromReadableStream(readableStream: ReadableStream, contentType?: string, contentSize?: number): Promise<IFile>;
+  fromReadableStream(readableStream: Readable, contentType?: string, contentSize?: number): Promise<IFile>;
   fromFile(localFilePath: string, contentType?: string): Promise<IFile>;
   fromUrl(url: string, options?: any): Promise<IFile>;
   toJSON(): any;