diff --git a/packages/client/src/sync/fetcher/fetcher.ts b/packages/client/src/sync/fetcher/fetcher.ts
index 72b1b256579..1983a23dde9 100644
--- a/packages/client/src/sync/fetcher/fetcher.ts
+++ b/packages/client/src/sync/fetcher/fetcher.ts
@@ -65,11 +65,6 @@ export abstract class Fetcher<JobTask, JobResult, StorageItem> extends Readable
   protected destroyWhenDone: boolean // Destroy the fetcher once we are finished processing each task.
   syncErrored?: Error
 
-  private _readableState?: {
-    // This property is inherited from Readable. We only need `length`.
-    length: number
-  }
-
   private writer: Writable | null = null
 
   /**
@@ -352,10 +347,13 @@ export abstract class Fetcher<JobTask, JobResult, StorageItem> extends Readable
       return false
     }
     const jobStr = this.jobStr(job)
-    if (this._readableState === undefined || this._readableState!.length > this.maxQueue) {
+    if (
+      (this as any)._readableState === undefined ||
+      (this as any)._readableState!.length > this.maxQueue
+    ) {
       this.DEBUG &&
         this.debug(
-          `Readable state length=${this._readableState!.length} exceeds max queue size=${
+          `Readable state length=${(this as any)._readableState!.length} exceeds max queue size=${
             this.maxQueue
           }, skip job ${jobStr} execution.`,
         )
diff --git a/packages/client/test/sync/fetcher/fetcher.spec.ts b/packages/client/test/sync/fetcher/fetcher.spec.ts
index a336916c549..458dc53f145 100644
--- a/packages/client/test/sync/fetcher/fetcher.spec.ts
+++ b/packages/client/test/sync/fetcher/fetcher.spec.ts
@@ -76,7 +76,7 @@ describe('should handle expiration', async () => {
     })
 
     fetcher['in'].insert(job as any)
-    fetcher['_readableState'] = []
+    ;(<any>fetcher)['_readableState'] = []
     fetcher['running'] = true
     fetcher['total'] = 10
     fetcher.next()