commit 7cdb563c9894600c6a739ec268f8673d6122006f
author Simon Binder <oss@simonbinder.eu> Mon Feb 28 16:29:44 2022 +0100
committer Simon Binder <oss@simonbinder.eu> Mon Feb 28 16:29:44 2022 +0100
tree e197085d75297262010785b12fb0abe1d7fa6c5f
parent ce8aae4825ac4cbed80829cd0d6e181b924b3db2

Make input stream private in block reader

lib/src/utils.dart

diff --git a/lib/src/utils.dart b/lib/src/utils.dart
index 25ff45b..4fa75b1 100644
--- a/lib/src/utils.dart
+++ b/lib/src/utils.dart
@@ -237,9 +237,9 @@
   }
 }
 
-/// An optimized reader reading 512-byte blocks from an [input] stream.
+/// An optimized reader reading 512-byte blocks from an input stream.
 class BlockReader {
-  final Stream<List<int>> input;
+  final Stream<List<int>> _input;
   StreamSubscription<List<int>>? _subscription;
   bool _isClosed = false;
 
@@ -280,7 +280,7 @@
   /// starting at this offset.
   int _offsetInTrailingData = 0;
 
-  BlockReader(this.input);
+  BlockReader(this._input);
 
   /// Emits full blocks.
   ///
@@ -403,7 +403,7 @@
 
     final sub = _subscription;
     if (sub == null) {
-      _subscription = input.listen(_onData,
+      _subscription = _input.listen(_onData,
           onError: _onError, onDone: _onDone, cancelOnError: true);
     } else {
       sub.resume();