Skip to content

Commit d725d79

Browse files
committed
refactor: code cleanups
Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
1 parent b56fff8 commit d725d79

File tree

3 files changed

+4
-8
lines changed

3 files changed

+4
-8
lines changed

src/pools/abstract-pool.ts

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -971,9 +971,7 @@ export abstract class AbstractPool<
971971
this.started = false
972972
}
973973

974-
private async sendKillMessageToWorker(
975-
workerNodeKey: number,
976-
): Promise<void> {
974+
private async sendKillMessageToWorker(workerNodeKey: number): Promise<void> {
977975
await new Promise<void>((resolve, reject) => {
978976
if (this.workerNodes?.[workerNodeKey] == null) {
979977
// FIXME: should reject with an error

src/pools/thread/fixed.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -28,9 +28,9 @@ export class FixedThreadPool<
2828
numberOfThreads: number,
2929
fileURL: URL,
3030
opts: PoolOptions<Data> = {},
31-
maximumNumberOfWorkers?: number,
31+
maximumNumberOfThreads?: number,
3232
) {
33-
super(numberOfThreads, fileURL, opts, maximumNumberOfWorkers)
33+
super(numberOfThreads, fileURL, opts, maximumNumberOfThreads)
3434
}
3535
/** @inheritDoc */
3636
protected isMain(): boolean {

tests/pools/selection-strategies/worker-choice-strategy-context.test.mjs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -192,9 +192,7 @@ Deno.test('Worker choice strategy context test suite', async (t) => {
192192
workerChoiceStrategyStub,
193193
)
194194
expect(() => workerChoiceStrategyContext.execute()).toThrow(
195-
new RangeError(
196-
'Maximum call stack size exceeded',
197-
),
195+
new RangeError('Maximum call stack size exceeded'),
198196
)
199197
workerChoiceStrategyStub.hasPoolWorkerNodesReady.restore()
200198
},

0 commit comments

Comments
 (0)