|
|
@@ -127,12 +127,19 @@ function fetch(...args:any):Promise {
|
|
127
|
127
|
}
|
|
128
|
128
|
})
|
|
129
|
129
|
|
|
|
130
|
+ let stateEvent = emitter.addListener('RNFetchBlobState', (e) => {
|
|
|
131
|
+ if(e.taskId === taskId && promise.onUploadProgress) {
|
|
|
132
|
+ promise.onStateChange(e)
|
|
|
133
|
+ }
|
|
|
134
|
+ })
|
|
|
135
|
+
|
|
130
|
136
|
let req = RNFetchBlob[nativeMethodName]
|
|
131
|
137
|
req(options, taskId, method, url, headers || {}, body, (err, data) => {
|
|
132
|
138
|
|
|
133
|
139
|
// task done, remove event listener
|
|
134
|
140
|
subscription.remove()
|
|
135
|
141
|
subscriptionUpload.remove()
|
|
|
142
|
+ stateEvent.remove()
|
|
136
|
143
|
if(err)
|
|
137
|
144
|
reject(new Error(err, data))
|
|
138
|
145
|
else {
|