Compare commits

...

4 Commits

4 changed files with 14 additions and 3 deletions

View File

@ -1,5 +1,15 @@
# Changelog
## 2024-10-16 - 3.1.10 - fix(VirtualStream)
Fix stream closure logic in `writeToWebstream` method
- Added `writer.releaseLock()` call before closing WritableStream when `closingBit` is received in `writeToWebstream` method.
## 2024-10-16 - 3.1.9 - fix(VirtualStream)
Ensure writable streams are correctly closed asynchronously to prevent potential sync issues.
- Updated VirtualStream to use 'await' when closing writable streams, ensuring proper asynchronous handling.
## 2024-10-16 - 3.1.8 - fix(VirtualStream)
Fix stream closing behavior to correctly handle closing bits

View File

@ -1,6 +1,6 @@
{
"name": "@api.global/typedrequest",
"version": "3.1.8",
"version": "3.1.10",
"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",

View File

@ -3,6 +3,6 @@
*/
export const commitinfo = {
name: '@api.global/typedrequest',
version: '3.1.8',
version: '3.1.10',
description: 'A TypeScript library for making typed requests towards APIs, including facilities for handling requests, routing, and virtual stream handling.'
}

View File

@ -404,7 +404,8 @@ export class VirtualStream<T = Uint8Array> implements plugins.typedRequestInterf
while(this.keepAlive || this.receiveBackpressuredArray.checkHasItems()) {
const value = await this.fetchData();
if (value === closingBit) {
writableStreamArg.close();
writer.releaseLock();
await writableStreamArg.close();
break;
}
await writer.write(value);