refactor: _receivedCallback is a more accurate name

jacobbubu · Nov 5, 2020 · 61961fe · 61961fe
1 parent 65191ff
commit 61961fe
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/src/mesh-stream/port-stream/mesh-read-man.ts b/src/mesh-stream/port-stream/mesh-read-man.ts
@@ -17,7 +17,7 @@ export interface MeshReadManOptions {
 export class MeshReadMan<Out> {
   private _buffer: Out[] = []
   private _requestList: MeshRead<Out>[] = []
-  private _readCallback: OnReceivedCallback | null = null
+  private _receivedCallback: OnReceivedCallback | null = null
   private _timerId: NodeJS.Timeout | null = null
   private _endOrError: pull.EndOrError = null
   private _abort: pull.EndOrError = null
@@ -50,7 +50,7 @@ export class MeshReadMan<Out> {
       return readCb(true)
     }
 
-    this._readCallback = readCb
+    this._receivedCallback = readCb
     this._buffer.push(data)
 
     if (this.drainAbort()) return
@@ -178,9 +178,9 @@ export class MeshReadMan<Out> {
       }
     }
     // should we read more data to fill the buffer?
-    if (this._buffer.length < DefaultWindowSize && this._readCallback) {
-      const t = this._readCallback
-      this._readCallback = null
+    if (this._buffer.length < DefaultWindowSize && this._receivedCallback) {
+      const t = this._receivedCallback
+      this._receivedCallback = null
       t()
     }
   }