@@ -11,6 +11,7 @@ const eventEmitter = new NativeEventEmitter(ReactNativeBlobUtil);
11
11
12
12
// register message channel event handler.
13
13
eventEmitter . addListener ( 'ReactNativeBlobUtilMessage' , ( e ) => {
14
+ e = JSON . parse ( e ) ;
14
15
15
16
console . log ( 'add listener' )
16
17
if ( e . event === 'warn' ) {
@@ -190,31 +191,36 @@ export function fetch(...args: any): Promise {
190
191
191
192
// on progress event listener
192
193
subscription = eventEmitter . addListener ( 'ReactNativeBlobUtilProgress' , ( e ) => {
194
+ e = JSON . parse ( e ) ;
193
195
if ( e . taskId === taskId && promise . onProgress ) {
194
196
promise . onProgress ( e . written , e . total , e . chunk ) ;
195
197
}
196
198
} ) ;
197
199
198
200
subscriptionUpload = eventEmitter . addListener ( 'ReactNativeBlobUtilProgress-upload' , ( e ) => {
201
+ e = JSON . parse ( e ) ;
199
202
if ( e . taskId === taskId && promise . onUploadProgress ) {
200
203
promise . onUploadProgress ( e . written , e . total ) ;
201
204
}
202
205
} ) ;
203
206
204
207
stateEvent = eventEmitter . addListener ( 'ReactNativeBlobUtilState' , ( e ) => {
208
+ e = JSON . parse ( e ) ;
205
209
console . log ( 'state' , e , typeof e , taskId , e . taskId )
206
210
if ( e . taskId === taskId )
207
211
respInfo = e ;
208
212
promise . onStateChange && promise . onStateChange ( e ) ;
209
213
} ) ;
210
214
211
215
subscription = eventEmitter . addListener ( 'ReactNativeBlobUtilExpire' , ( e ) => {
216
+ e = JSON . parse ( e ) ;
212
217
if ( e . taskId === taskId && promise . onExpire ) {
213
218
promise . onExpire ( e ) ;
214
219
}
215
220
} ) ;
216
221
217
222
partEvent = eventEmitter . addListener ( 'ReactNativeBlobUtilServerPush' , ( e ) => {
223
+ e = JSON . parse ( e ) ;
218
224
if ( e . taskId === taskId && promise . onPartData ) {
219
225
promise . onPartData ( e . chunk ) ;
220
226
}
0 commit comments