stream: remove duplicated utility · nodejs/node@1397d8c · GitHub
Skip to content

Commit 1397d8c

Browse files
committed
stream: remove duplicated utility
Signed-off-by: Antoine du Hamel <duhamelantoine1995@gmail.com> PR-URL: #63031 Reviewed-By: Matteo Collina <matteo.collina@gmail.com> Reviewed-By: James M Snell <jasnell@gmail.com>
1 parent d7188af commit 1397d8c

5 files changed

Lines changed: 33 additions & 51 deletions

File tree

‎lib/internal/webstreams/queuingstrategies.js‎

Lines changed: 1 addition & 8 deletions

‎lib/internal/webstreams/readablestream.js‎

Lines changed: 6 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -106,15 +106,16 @@ const {
106106
enqueueValueWithSize,
107107
extractHighWaterMark,
108108
extractSizeAlgorithm,
109-
lazyTransfer,
109+
getNonWritablePropertyDescriptor,
110110
isBrandCheck,
111-
resetQueue,
112-
setPromiseHandled,
111+
kState,
112+
kType,
113+
lazyTransfer,
113114
nonOpCancel,
114115
nonOpPull,
115116
nonOpStart,
116-
kType,
117-
kState,
117+
resetQueue,
118+
setPromiseHandled,
118119
} = require('internal/webstreams/util');
119120

120121
const {
@@ -171,14 +172,6 @@ function lazyReadableReleasingError() {
171172
return releasingError;
172173
}
173174

174-
const getNonWritablePropertyDescriptor = (value) => {
175-
return {
176-
__proto__: null,
177-
configurable: true,
178-
value,
179-
};
180-
};
181-
182175
/**
183176
* @typedef {import('../abort_controller').AbortSignal} AbortSignal
184177
* @typedef {import('./queuingstrategies').QueuingStrategy} QueuingStrategy

‎lib/internal/webstreams/transformstream.js‎

Lines changed: 3 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -47,11 +47,12 @@ const {
4747
customInspect,
4848
extractHighWaterMark,
4949
extractSizeAlgorithm,
50+
getNonWritablePropertyDescriptor,
5051
isBrandCheck,
51-
nonOpFlush,
52-
kType,
5352
kState,
53+
kType,
5454
nonOpCancel,
55+
nonOpFlush,
5556
} = require('internal/webstreams/util');
5657

5758
const {
@@ -72,13 +73,6 @@ const {
7273
const assert = require('internal/assert');
7374

7475
const kSkipThrow = Symbol('kSkipThrow');
75-
const getNonWritablePropertyDescriptor = (value) => {
76-
return {
77-
__proto__: null,
78-
configurable: true,
79-
value,
80-
};
81-
};
8276

8377
/**
8478
* @typedef {import('./queuingstrategies').QueuingStrategy

‎lib/internal/webstreams/util.js‎

Lines changed: 16 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,14 @@ const AsyncIterator = {
5252
return: undefined,
5353
};
5454

55+
const getNonWritablePropertyDescriptor = (value) => {
56+
return {
57+
__proto__: null,
58+
configurable: true,
59+
value,
60+
};
61+
};
62+
5563
function extractHighWaterMark(value, defaultHWM) {
5664
if (value === undefined) return defaultHWM;
5765
value = +value;
@@ -204,25 +212,26 @@ module.exports = {
204212
ArrayBufferViewGetByteOffset,
205213
AsyncIterator,
206214
canCopyArrayBuffer,
207-
createPromiseCallback,
208215
cloneAsUint8Array,
209216
copyArrayBuffer,
217+
createPromiseCallback,
210218
customInspect,
211219
dequeueValue,
212220
enqueueValueWithSize,
213221
extractHighWaterMark,
214222
extractSizeAlgorithm,
215-
lazyTransfer,
223+
getNonWritablePropertyDescriptor,
216224
isBrandCheck,
217225
isPromisePending,
218-
peekQueueValue,
219-
resetQueue,
220-
setPromiseHandled,
226+
kState,
227+
kType,
228+
lazyTransfer,
221229
nonOpCancel,
222230
nonOpFlush,
223231
nonOpPull,
224232
nonOpStart,
225233
nonOpWrite,
226-
kType,
227-
kState,
234+
peekQueueValue,
235+
resetQueue,
236+
setPromiseHandled,
228237
};

‎lib/internal/webstreams/writablestream.js‎

Lines changed: 7 additions & 14 deletions

0 commit comments

Comments
 (0)