StreamWorker

:StreamWorker

StreamWorker class - intended for internal use

This class provides control over the subprocesses, including:

• spawning
• communicating
• delivering streams

Kind: static class Internal:

• :StreamWorker
  • new StreamWorker()
  • streamWorker.spawn() ⇄ StreamWorker
  • streamWorker.delegate(input, delegateFunc, [plugins]) DataStream
  • StreamWorker:fork([count]) ⇄ Array.<StreamWorker>
  • StreamWorker:_getWorker() ⇄ StreamWorker

new StreamWorker()

Private constructor

streamWorker.spawn() : StreamWorker ⇄

Spawns the worker if necessary and provides the port information to it.

Kind: instance method of StreamWorker

streamWorker.delegate(input, delegateFunc, [plugins]) : DataStream

Delegates a stream to the child using tcp socket.

The stream gets serialized using JSON and passed on to the sub-process. The sub-process then performs transforms on the stream and pushes them back to the main process. The stream gets deserialized and outputted to the returned DataStream.

Kind: instance method of StreamWorker Returns: DataStream - stream after transforms and back to the main process.

Param	Type	Default	Description
input	DataStream		stream to be delegated
delegateFunc	Array.<TeeCallback> | Array		Array of transforms or arrays describing ['module', 'method']
[plugins]	Array.<any>	[]	List of plugins to load in the child

StreamWorker:fork([count]) : Array.<StreamWorker> ⇄

Spawns (Preforks) a given number of subprocesses and returns the worker asynchronously.

Kind: static method of StreamWorker Returns: Array.<StreamWorker> - list of StreamWorkers

Param	Type	Default	Description
[count]	number	os.cpus().length	Number of processes to spawn. If other subprocesses are active only the missing ones will be spawned.

StreamWorker:_getWorker() : StreamWorker ⇄

Picks next worker (not necessarily free one!)

Kind: static method of StreamWorker