Skip to content

Commit d924e72

Browse files
authored
Fix CI (#4)
1 parent 4b30b3a commit d924e72

File tree

3 files changed

+11
-11
lines changed

3 files changed

+11
-11
lines changed

.github/workflows/ci.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ jobs:
4949
name: Deploy
5050
runs-on: ubuntu-latest
5151
if: "startsWith(github.ref, 'refs/tags/') && github.repository == 'sass/sync-message-port'"
52-
needs: [static_analysis, tests, sass_spec]
52+
needs: [static_analysis, tests]
5353

5454
steps:
5555
- uses: actions/checkout@v4

lib/index.test.ts

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ describe('SyncMessagePort', () => {
3232
port.close();
3333
}, 100);
3434
`,
35-
channel.port2
35+
channel.port2,
3636
);
3737

3838
expect(port.receiveMessage()).toEqual('done!');
@@ -64,7 +64,7 @@ describe('SyncMessagePort', () => {
6464
port.postMessage('done!');
6565
port.close();
6666
`,
67-
channel.port2
67+
channel.port2,
6868
);
6969

7070
expect(port.receiveMessage()).toEqual('message1');
@@ -152,22 +152,22 @@ function spawnWorker(source: string, port: MessagePort): Worker {
152152
file,
153153
`
154154
const {SyncMessagePort} = require(${JSON.stringify(
155-
p.join(p.dirname(__filename), 'index')
155+
p.join(p.dirname(__filename), 'index'),
156156
)});
157157
const {workerData} = require('worker_threads');
158158
159159
const port = new SyncMessagePort(workerData);
160160
161161
${source}
162-
`
162+
`,
163163
);
164164

165165
const worker = new Worker(
166166
`
167167
require('ts-node').register();
168168
require(${JSON.stringify(p.resolve(file.substring(0, file.length - 3)))});
169169
`,
170-
{eval: true, workerData: port, transferList: [port]}
170+
{eval: true, workerData: port, transferList: [port]},
171171
);
172172

173173
worker.on('error', error => {

lib/index.ts

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,7 @@ export class SyncMessagePort extends EventEmitter {
7878
if (!buffer) {
7979
throw new Error(
8080
'new SyncMessagePort() must be passed a port from ' +
81-
'SyncMessagePort.createChannel().'
81+
'SyncMessagePort.createChannel().',
8282
);
8383
}
8484
this.buffer = new Int32Array(buffer as SharedArrayBuffer);
@@ -87,7 +87,7 @@ export class SyncMessagePort extends EventEmitter {
8787
this.port.on(event, listener);
8888
});
8989
this.on('removeListener', (event, listener) =>
90-
this.port.removeListener(event, listener)
90+
this.port.removeListener(event, listener),
9191
);
9292
}
9393

@@ -103,7 +103,7 @@ export class SyncMessagePort extends EventEmitter {
103103
this.buffer,
104104
0,
105105
BufferState.AwaitingMessage,
106-
BufferState.MessageSent
106+
BufferState.MessageSent,
107107
) === BufferState.AwaitingMessage
108108
) {
109109
Atomics.notify(this.buffer, 0);
@@ -127,7 +127,7 @@ export class SyncMessagePort extends EventEmitter {
127127
if (this.listenerCount('message')) {
128128
throw new Error(
129129
'SyncMessageChannel.receiveMessage() may not be called while there ' +
130-
'are message listeners.'
130+
'are message listeners.',
131131
);
132132
}
133133

@@ -141,7 +141,7 @@ export class SyncMessagePort extends EventEmitter {
141141
this.buffer,
142142
0,
143143
BufferState.MessageSent,
144-
BufferState.AwaitingMessage
144+
BufferState.AwaitingMessage,
145145
) === BufferState.Closed
146146
) {
147147
throw new Error("The SyncMessagePort's channel is closed.");

0 commit comments

Comments
 (0)