Update ns_input_stream.dart

dart-lang · Sep 27, 2024 · a0b5769 · a0b5769
1 parent d40f878
commit a0b5769
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pkgs/objective_c/lib/src/ns_input_stream.dart b/pkgs/objective_c/lib/src/ns_input_stream.dart
@@ -24,11 +24,14 @@ extension NSInputStreamStreamExtension on Stream<List<int>> {
         DartInputStreamAdapter.inputStreamWithPort_(port.sendPort.nativePort);
     late final StreamSubscription<dynamic> dataSubscription;
 
+    print('Here1');
     dataSubscription = listen((data) {
       if (inputStream.addData_(data.toNSData()) > maxReadAheadSize) {
+        print('pause');
         dataSubscription.pause();
       }
     }, onError: (Object e) {
+      print('error');
       final d = NSMutableDictionary.new1();
       d.setObject_forKey_(e.toString().toNSString(), NSLocalizedDescriptionKey);
       inputStream.setError_(NSError.errorWithDomain_code_userInfo_(
@@ -37,6 +40,7 @@ extension NSInputStreamStreamExtension on Stream<List<int>> {
 
     dataSubscription.pause();
     port.listen((count) {
+      print('count: $count');
       // -1 indicates that the `NSInputStream` is closed. All other values
       // indicate that the `NSInputStream` needs more data.
       if (count == -1) {