fix(WebDuplexStream): Fix variable naming inconsistency in WebDuplexStream test
This commit is contained in:
parent
6a2ef1b152
commit
e138bca39d
@ -1,5 +1,11 @@
|
|||||||
# Changelog
|
# Changelog
|
||||||
|
|
||||||
|
## 2024-10-14 - 3.1.2 - fix(WebDuplexStream)
|
||||||
|
Fix variable naming inconsistency in WebDuplexStream test
|
||||||
|
|
||||||
|
- Changed variable names from 'transformStream' to 'webDuplexStream' for consistency.
|
||||||
|
- Renamed 'writableStream' and 'readableStream' to 'writer' and 'reader' respectively.
|
||||||
|
|
||||||
## 2024-10-13 - 3.1.1 - fix(WebDuplexStream)
|
## 2024-10-13 - 3.1.1 - fix(WebDuplexStream)
|
||||||
Improved read/write interface and error handling in WebDuplexStream
|
Improved read/write interface and error handling in WebDuplexStream
|
||||||
|
|
||||||
|
@ -28,22 +28,22 @@ tap.test('WebDuplexStream should handle transform with a write function', async
|
|||||||
const input = [1, 2, 3, 4, 5];
|
const input = [1, 2, 3, 4, 5];
|
||||||
const expectedOutput = [2, 4, 6, 8, 10];
|
const expectedOutput = [2, 4, 6, 8, 10];
|
||||||
|
|
||||||
const transformStream = new webstream.WebDuplexStream<number, number>({
|
const webDuplexStream = new webstream.WebDuplexStream<number, number>({
|
||||||
writeFunction: async (chunk, { push }) => {
|
writeFunction: async (chunk, { push }) => {
|
||||||
// Push the doubled number into the stream
|
// Push the doubled number into the stream
|
||||||
push(chunk * 2);
|
push(chunk * 2);
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
|
|
||||||
const writableStream = transformStream.writable.getWriter();
|
const writer = webDuplexStream.writable.getWriter();
|
||||||
const readableStream = transformStream.readable.getReader();
|
const reader = webDuplexStream.readable.getReader();
|
||||||
|
|
||||||
const output: number[] = [];
|
const output: number[] = [];
|
||||||
|
|
||||||
// Read from the stream asynchronously
|
// Read from the stream asynchronously
|
||||||
const readPromise = (async () => {
|
const readPromise = (async () => {
|
||||||
while (true) {
|
while (true) {
|
||||||
const { value, done } = await readableStream.read();
|
const { value, done } = await reader.read();
|
||||||
if (done) break;
|
if (done) break;
|
||||||
if (value !== undefined) {
|
if (value !== undefined) {
|
||||||
output.push(value);
|
output.push(value);
|
||||||
@ -53,9 +53,9 @@ tap.test('WebDuplexStream should handle transform with a write function', async
|
|||||||
|
|
||||||
// Write to the stream
|
// Write to the stream
|
||||||
for (const num of input) {
|
for (const num of input) {
|
||||||
await writableStream.write(num);
|
await writer.write(num);
|
||||||
}
|
}
|
||||||
await writableStream.close();
|
await writer.close();
|
||||||
|
|
||||||
// Wait for the reading to complete
|
// Wait for the reading to complete
|
||||||
await readPromise;
|
await readPromise;
|
||||||
|
@ -3,6 +3,6 @@
|
|||||||
*/
|
*/
|
||||||
export const commitinfo = {
|
export const commitinfo = {
|
||||||
name: '@push.rocks/smartstream',
|
name: '@push.rocks/smartstream',
|
||||||
version: '3.1.1',
|
version: '3.1.2',
|
||||||
description: 'A library to simplify the creation and manipulation of Node.js streams, providing utilities for handling transform, duplex, and readable/writable streams effectively in TypeScript.'
|
description: 'A library to simplify the creation and manipulation of Node.js streams, providing utilities for handling transform, duplex, and readable/writable streams effectively in TypeScript.'
|
||||||
}
|
}
|
||||||
|
@ -3,6 +3,6 @@
|
|||||||
*/
|
*/
|
||||||
export const commitinfo = {
|
export const commitinfo = {
|
||||||
name: '@push.rocks/smartstream',
|
name: '@push.rocks/smartstream',
|
||||||
version: '3.1.1',
|
version: '3.1.2',
|
||||||
description: 'A library to simplify the creation and manipulation of Node.js streams, providing utilities for handling transform, duplex, and readable/writable streams effectively in TypeScript.'
|
description: 'A library to simplify the creation and manipulation of Node.js streams, providing utilities for handling transform, duplex, and readable/writable streams effectively in TypeScript.'
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user