Compare commits
2 Commits
Author | SHA1 | Date | |
---|---|---|---|
c61e30fe64 | |||
4887c07ef3 |
@ -1,5 +1,10 @@
|
||||
# Changelog
|
||||
|
||||
## 2024-10-16 - 3.1.5 - fix(virtualstream)
|
||||
Add console log for debugging backpressure feedback loop
|
||||
|
||||
- Inserted a console log message to provide insight when waiting due to backpressure in the workOnQueue method.
|
||||
|
||||
## 2024-10-16 - 3.1.4 - fix(VirtualStream)
|
||||
Corrected the logic for backpressure handling in response
|
||||
|
||||
|
@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "@api.global/typedrequest",
|
||||
"version": "3.1.4",
|
||||
"version": "3.1.5",
|
||||
"private": false,
|
||||
"description": "A TypeScript library for making typed requests towards APIs, including facilities for handling requests, routing, and virtual stream handling.",
|
||||
"main": "dist_ts/index.js",
|
||||
|
@ -3,6 +3,6 @@
|
||||
*/
|
||||
export const commitinfo = {
|
||||
name: '@api.global/typedrequest',
|
||||
version: '3.1.4',
|
||||
version: '3.1.5',
|
||||
description: 'A TypeScript library for making typed requests towards APIs, including facilities for handling requests, routing, and virtual stream handling.'
|
||||
}
|
||||
|
@ -180,6 +180,7 @@ export class VirtualStream<T = Uint8Array> implements plugins.typedRequestInterf
|
||||
while (this.sendBackpressuredArray.data.length > 0 || otherSideHasNext) {
|
||||
if (otherSideIsBackpressured) {
|
||||
while (otherSideIsBackpressured) {
|
||||
console.log('waiting for feedback because of backpressure...');
|
||||
await plugins.smartdelay.delayFor(50);
|
||||
await getFeedback();
|
||||
}
|
||||
|
Reference in New Issue
Block a user