Skip to content
This repository was archived by the owner on Jul 30, 2024. It is now read-only.

Commit b8610d4

Browse files
authored
Merge pull request #271 from exoego/worker
[worker_thread] Add transferList and resourceLimits
2 parents 5cb395f + ae9124f commit b8610d4

File tree

4 files changed

+28
-0
lines changed

4 files changed

+28
-0
lines changed
Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
package io.scalajs.nodejs.worker_threads
2+
3+
import net.exoego.scalajs.types.util.Factory
4+
5+
import scala.scalajs.js
6+
7+
@Factory
8+
trait ResourceLimits extends js.Object {
9+
var maxYoungGenerationSizeMb: js.UndefOr[Int] = js.undefined
10+
var maxOldGenerationSizeMb: js.UndefOr[Int] = js.undefined
11+
var codeRangeSizeMb: js.UndefOr[Int] = js.undefined
12+
var stackSizeMb: js.UndefOr[Int] = js.undefined
13+
}

app/nodejs-v14/src/main/scala/io/scalajs/nodejs/worker_threads/Worker.scala

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,7 @@
11
package io.scalajs.nodejs.worker_threads
22

3+
import com.thoughtworks.enableIf
4+
35
import scala.scalajs.js
46
import scala.scalajs.js.|
57
import scala.scalajs.js.annotation.JSImport
@@ -20,4 +22,7 @@ class Worker(filename: String, workerOptions: WorkerOptions) extends js.Object w
2022
def stderr: io.scalajs.nodejs.stream.Readable = js.native
2123
def stdout: io.scalajs.nodejs.stream.Readable = js.native
2224
def stdin: io.scalajs.nodejs.stream.Writable | Null = js.native
25+
26+
@enableIf(io.scalajs.nodejs.internal.CompilerSwitches.gteNodeJs12)
27+
def resourceLimits: ResourceLimits = js.native
2328
}

app/nodejs-v14/src/main/scala/io/scalajs/nodejs/worker_threads/WorkerOptions.scala

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
package io.scalajs.nodejs.worker_threads
22

3+
import com.thoughtworks.enableIf
34
import net.exoego.scalajs.types.util.Factory
45

56
import scala.scalajs.js
@@ -13,4 +14,10 @@ trait WorkerOptions extends js.Object {
1314
var stdout: js.UndefOr[Boolean] = js.undefined
1415
var stderr: js.UndefOr[Boolean] = js.undefined
1516
var workerData: js.UndefOr[js.Any] = js.undefined
17+
18+
@enableIf(io.scalajs.nodejs.internal.CompilerSwitches.gteNodeJs14)
19+
var transferList: js.UndefOr[js.Array[js.Object]] = js.undefined
20+
21+
@enableIf(io.scalajs.nodejs.internal.CompilerSwitches.gteNodeJs12)
22+
var resourceLimits: js.UndefOr[ResourceLimits] = js.undefined
1623
}

app/nodejs-v14/src/main/scala/io/scalajs/nodejs/worker_threads/WorkerThreads.scala

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,9 @@ trait WorkerThreads extends js.Object {
2323

2424
@enableIf(io.scalajs.nodejs.internal.CompilerSwitches.gteNodeJs12)
2525
def receiveMessageOnPort(port: MessagePort): js.UndefOr[js.Object] = js.native
26+
27+
@enableIf(io.scalajs.nodejs.internal.CompilerSwitches.gteNodeJs12)
28+
def resourceLimits: ResourceLimits = js.native
2629
}
2730

2831
@js.native

0 commit comments

Comments
 (0)