corrected stream showing of characters

Author: ehsan6sha

android/src/main/java/land/fx/fula/FulaModule.java

@@ -1962,7 +1962,10 @@ private void pollIterator(fulamobile.StreamIterator iterator, Promise promise) {
           , 50); // Reduced delay for better responsiveness
       }
   } catch (Exception e) {
-      if (e.getMessage().contains("timeout")) {
+      if (e.getMessage() != null && e.getMessage().contains("EOF")) {
+          emitEvent("onStreamingCompleted", null);
+          promise.resolve(null);
+      } else if (e.getMessage() != null && e.getMessage().contains("timeout")) {
           // Retry on timeout
           new Handler(Looper.getMainLooper()).post(() -> 
               pollIterator(iterator, promise)

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@functionland/react-native-fula",
-  "version": "1.55.0",
+  "version": "1.55.1",
   "description": "This package is a bridge to use the Fula libp2p protocols in the react-native which is using wnfs",
   "type": "module",
   "main": "lib/commonjs/index",

src/protocols/fx-ai.ts

@@ -80,8 +80,15 @@ import { DeviceEventEmitter } from 'react-native';
 
       const errorHandler = (error: string) => {
         if (active) {
-          cleanup();
-          reject(new Error(error || 'Stream error occurred'));
+            cleanup();
+            if (error.includes('EOF')) {
+                // Treat EOF as successful completion
+                console.log('Stream completed with EOF');
+                resolve(fullResponse);
+            } else {
+                console.error('Stream error:', error);
+                reject(new Error(error || 'Unknown stream error'));
+            }
         }
       };
 
@@ -90,11 +97,15 @@ import { DeviceEventEmitter } from 'react-native';
       DeviceEventEmitter.addListener('onStreamError', errorHandler);
 
       Fula.streamChunks(streamID)
-        .catch(error => {
-          if (active) {
+      .catch(error => {
+        if (active) {
             cleanup();
-            reject(error);
-          }
-        });
+            if (error.message.includes('EOF')) {
+                resolve(fullResponse);
+            } else {
+                reject(error);
+            }
+        }
+      });
     });
   };