Class: Parent

Constructor

new Parent(threadProcessPath)

Manage communication between socket wrapper and worker thread

Parameters:

Name	Type	Description
`threadProcessPath`	string	path to the thread process

Source: thread.js, line 44

Members

_resolveApply :Object.<string, function()>

Type:

Object.<string, function()>

Source: thread.js, line 71

callbacks :Object.<string, function()>

Type:

Object.<string, function()>

Source: thread.js, line 62

socketWrappers :Array.<SocketWrapper>

current socket wrapper connected in thread

Type:

Array.<SocketWrapper>

Source: thread.js, line 68

worker :workerThreads.Worker

worker

Type:

workerThreads.Worker

Source: thread.js, line 59

Methods

addSocketWrapper(socketWrapper)

Add a socket wrapper in this thread

Parameters:

Name	Type	Description
`socketWrapper`	SocketWrapper	socket wrapper to add

Source: thread.js, line 97

apply(msgType, data) → {Promise}

Same as this.post but return a promise resolving when thread child has applied message

Parameters:

Name	Type	Description
`msgType`	string	message type
`data`	object	seriablizable data

Source: thread.js, line 163

Returns:

promise resolving when thread child has applied message

Type:: Promise

on(msgType, callback)

Receive message from child thread

Parameters:

Name	Type	Description
`msgType`	string	message type
`callback`	function	callback to apply

Source: thread.js, line 151

post(msgType, data)

Send Message to child thread

Parameters:

Name	Type	Description
`msgType`	string	message type
`data`	object	seriablizable data

Source: thread.js, line 138

removeSocketWrapper(socketWrapper) → {boolean}

Parameters:

Name	Type	Description
`socketWrapper`	SocketWrapper	socket wrapper to remove

Source: thread.js, line 121

Returns:

true if removed

Type:: boolean