refactor: make it obvious what the subscribe function does.

Jason3S · Jul 18, 2021 · a13b313 · a13b313
1 parent fa545af
commit a13b313
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/rxToStream.ts b/src/rxToStream.ts
@@ -57,7 +57,7 @@ class ReadableObservableStream<T> extends stream.Readable {
     ) {
         super(streamOptions(options));
         if (options.lazy === false) {
-            this.subscribe();
+            this.subscribeIfNecessary();
         }
     }
 
@@ -70,7 +70,7 @@ class ReadableObservableStream<T> extends stream.Readable {
     _read() {
         const { _buffer } = this;
 
-        this.subscribe();
+        this.subscribeIfNecessary();
 
         if (_buffer.length > 0) {
             while (_buffer.length > 0) {
@@ -90,7 +90,7 @@ class ReadableObservableStream<T> extends stream.Readable {
         }
     }
 
-    private subscribe() {
+    private subscribeIfNecessary() {
         if (this._subscription) return;
 
         const { _buffer } = this;