diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml index 64408da..7a534fd 100644 --- a/.github/workflows/ci.yml +++ b/.github/workflows/ci.yml @@ -49,7 +49,7 @@ jobs: name: Deploy runs-on: ubuntu-latest if: "startsWith(github.ref, 'refs/tags/') && github.repository == 'sass/sync-message-port'" - needs: [static_analysis, tests, sass_spec] + needs: [static_analysis, tests] steps: - uses: actions/checkout@v4 diff --git a/lib/index.test.ts b/lib/index.test.ts index 4099827..aa9f251 100644 --- a/lib/index.test.ts +++ b/lib/index.test.ts @@ -32,7 +32,7 @@ describe('SyncMessagePort', () => { port.close(); }, 100); `, - channel.port2 + channel.port2, ); expect(port.receiveMessage()).toEqual('done!'); @@ -64,7 +64,7 @@ describe('SyncMessagePort', () => { port.postMessage('done!'); port.close(); `, - channel.port2 + channel.port2, ); expect(port.receiveMessage()).toEqual('message1'); @@ -152,14 +152,14 @@ function spawnWorker(source: string, port: MessagePort): Worker { file, ` const {SyncMessagePort} = require(${JSON.stringify( - p.join(p.dirname(__filename), 'index') + p.join(p.dirname(__filename), 'index'), )}); const {workerData} = require('worker_threads'); const port = new SyncMessagePort(workerData); ${source} - ` + `, ); const worker = new Worker( @@ -167,7 +167,7 @@ function spawnWorker(source: string, port: MessagePort): Worker { require('ts-node').register(); require(${JSON.stringify(p.resolve(file.substring(0, file.length - 3)))}); `, - {eval: true, workerData: port, transferList: [port]} + {eval: true, workerData: port, transferList: [port]}, ); worker.on('error', error => { diff --git a/lib/index.ts b/lib/index.ts index 1c17978..18334d7 100644 --- a/lib/index.ts +++ b/lib/index.ts @@ -78,7 +78,7 @@ export class SyncMessagePort extends EventEmitter { if (!buffer) { throw new Error( 'new SyncMessagePort() must be passed a port from ' + - 'SyncMessagePort.createChannel().' + 'SyncMessagePort.createChannel().', ); } this.buffer = new Int32Array(buffer as SharedArrayBuffer); @@ -87,7 +87,7 @@ export class SyncMessagePort extends EventEmitter { this.port.on(event, listener); }); this.on('removeListener', (event, listener) => - this.port.removeListener(event, listener) + this.port.removeListener(event, listener), ); } @@ -103,7 +103,7 @@ export class SyncMessagePort extends EventEmitter { this.buffer, 0, BufferState.AwaitingMessage, - BufferState.MessageSent + BufferState.MessageSent, ) === BufferState.AwaitingMessage ) { Atomics.notify(this.buffer, 0); @@ -127,7 +127,7 @@ export class SyncMessagePort extends EventEmitter { if (this.listenerCount('message')) { throw new Error( 'SyncMessageChannel.receiveMessage() may not be called while there ' + - 'are message listeners.' + 'are message listeners.', ); } @@ -141,7 +141,7 @@ export class SyncMessagePort extends EventEmitter { this.buffer, 0, BufferState.MessageSent, - BufferState.AwaitingMessage + BufferState.AwaitingMessage, ) === BufferState.Closed ) { throw new Error("The SyncMessagePort's channel is closed.");