File tree Expand file tree Collapse file tree 1 file changed +8
-2
lines changed Expand file tree Collapse file tree 1 file changed +8
-2
lines changed Original file line number Diff line number Diff line change @@ -180,19 +180,25 @@ namespace jsNode {
180
180
181
181
def getBody(r: NativeResponse): EffektAsyncIterator[js::NativeBytes] = {
182
182
val nextResolve = ref(promise::make())
183
+ val done = ref(false)
183
184
r.events.js::on(js::ev::data(), box { chunk =>
184
185
val waitingResolve = nextResolve.get().await()
185
186
nextResolve.set(promise::make())
186
187
waitingResolve.resolve(Some(chunk))
187
188
})
188
189
r.events.js::on(js::ev::end(), box { _ =>
189
190
val waitingResolve = nextResolve.get().await()
190
- nextResolve.set(promise::make())
191
+ // nextResolve.set(promise::make())
191
192
waitingResolve.resolve(None())
193
+ done.set(true)
192
194
})
193
195
EffektAsyncIterator(box {
194
196
val resPromise = promise::make()
195
- nextResolve.get().resolve(resPromise)
197
+ if (done.get()) {
198
+ resPromise.resolve(None())
199
+ } else {
200
+ nextResolve.get().resolve(resPromise)
201
+ }
196
202
resPromise
197
203
})
198
204
}
You can’t perform that action at this time.
0 commit comments