MessagePort
[<Interface>]
type MessagePort =
abstract member addListener (event: string, listener: obj -> unit) : MessagePort
abstract member addListenerClose (listener: Event -> unit) : MessagePort
abstract member addListenerMessage (listener: obj -> unit) : MessagePort
abstract member addListenerMessageerror (listener: exn -> unit) : MessagePort
abstract member close () : unit
abstract member emit (event: string, arg: obj) : bool
abstract member emitClose (ev: Event) : bool
abstract member emitMessage (value: obj) : bool
abstract member emitMessageerror (error: exn) : bool
abstract member hasRef () : bool
abstract member off (event: string, listener: obj -> unit, ?options: EventListenerOptions) : MessagePort
abstract member offClose (listener: Event -> unit, ?options: EventListenerOptions) : MessagePort
abstract member offMessage (listener: obj -> unit, ?options: EventListenerOptions) : MessagePort
abstract member offMessageerror (listener: exn -> unit, ?options: EventListenerOptions) : MessagePort
abstract member on (event: string, listener: obj -> unit) : MessagePort
abstract member onClose (listener: Event -> unit) : MessagePort
abstract member onMessage (listener: obj -> unit) : MessagePort
abstract member onMessageerror (listener: exn -> unit) : MessagePort
abstract member once (event: string, listener: obj -> unit) : MessagePort
abstract member onceClose (listener: Event -> unit) : MessagePort
abstract member onceMessage (listener: obj -> unit) : MessagePort
abstract member onceMessageerror (listener: exn -> unit) : MessagePort
abstract member postMessage (value: obj, ?transferList: Transferable array) : unit
abstract member ref () : unit
abstract member removeAllListeners (?type: string) : MessagePort
abstract member removeListener (event: string, listener: obj -> unit, ?options: EventListenerOptions) : MessagePort
abstract member removeListenerClose (listener: Event -> unit, ?options: EventListenerOptions) : MessagePort
abstract member removeListenerMessage (listener: obj -> unit, ?options: EventListenerOptions) : MessagePort
abstract member removeListenerMessageerror (listener: exn -> unit, ?options: EventListenerOptions) : MessagePort
abstract member start () : unit
abstract member unref () : unit| Assembly | Xantham.Fable.Node |
| Implements | NodeEventTarget |
Instances of the worker.MessagePort class represent one end of an asynchronous, two-way communications channel. It can be used to transfer structured data, memory regions and other MessagePorts between different Workers.
This implementation matches browser MessagePort s.
@since v10.5.0
Methods
abstract member addListener (event: string, listener: obj -> unit) : MessagePort
abstract member addListener (event: string, listener: obj -> unit) : MessagePortNode.js-specific extension to the EventTarget class that emulates the equivalent EventEmitter API. The only difference between addListener() and addEventListener() is that addListener() will return a reference to the EventTarget.
abstract member addListenerClose (listener: Event -> unit) : MessagePort
abstract member addListenerClose (listener: Event -> unit) : MessagePortaddListener(event: "close", listener: (ev: Event) => void): this
abstract member addListenerMessage (listener: obj -> unit) : MessagePort
abstract member addListenerMessage (listener: obj -> unit) : MessagePortaddListener(event: "message", listener: (value: any) => void): this
abstract member addListenerMessageerror (listener: exn -> unit) : MessagePort
abstract member addListenerMessageerror (listener: exn -> unit) : MessagePortaddListener(event: "messageerror", listener: (error: Error) => void): this
abstract member close () : unit
abstract member close () : unitDisables further sending of messages on either side of the connection. This method can be called when no further communication will happen over this MessagePort.
The 'close' event is emitted on both MessagePort instances that are part of the channel.
@since v10.5.0
abstract member emit (event: string, arg: obj) : bool
abstract member emit (event: string, arg: obj) : boolNode.js-specific extension to the EventTarget class that dispatches the arg to the list of handlers for type.
abstract member emitClose (ev: Event) : bool
abstract member emitClose (ev: Event) : boolemit(event: "close", ev: Event): boolean
abstract member emitMessage (value: obj) : bool
abstract member emitMessage (value: obj) : boolemit(event: "message", value: any): boolean
abstract member emitMessageerror (error: exn) : bool
abstract member emitMessageerror (error: exn) : boolemit(event: "messageerror", error: Error): boolean
abstract member hasRef () : bool
abstract member hasRef () : boolIf true, the MessagePort object will keep the Node.js event loop active.
@since v18.1.0, v16.17.0
abstract member off (event: string, listener: obj -> unit, ?options: EventListenerOptions) : MessagePort
abstract member off (event: string, listener: obj -> unit, ?options: EventListenerOptions) : MessagePortNode.js-specific alias for eventTarget.removeEventListener().
abstract member offClose (listener: Event -> unit, ?options: EventListenerOptions) : MessagePort
abstract member offClose (listener: Event -> unit, ?options: EventListenerOptions) : MessagePortoff(event: "close", listener: (ev: Event) => void, options?: EventListenerOptions): this
abstract member offMessage (listener: obj -> unit, ?options: EventListenerOptions) : MessagePort
abstract member offMessage (listener: obj -> unit, ?options: EventListenerOptions) : MessagePortoff(event: "message", listener: (value: any) => void, options?: EventListenerOptions): this
abstract member offMessageerror (listener: exn -> unit, ?options: EventListenerOptions) : MessagePort
abstract member offMessageerror (listener: exn -> unit, ?options: EventListenerOptions) : MessagePortoff(event: "messageerror", listener: (error: Error) => void, options?: EventListenerOptions): this
abstract member on (event: string, listener: obj -> unit) : MessagePort
abstract member on (event: string, listener: obj -> unit) : MessagePortNode.js-specific alias for eventTarget.addEventListener().
abstract member onClose (listener: Event -> unit) : MessagePort
abstract member onClose (listener: Event -> unit) : MessagePorton(event: "close", listener: (ev: Event) => void): this
abstract member onMessage (listener: obj -> unit) : MessagePort
abstract member onMessage (listener: obj -> unit) : MessagePorton(event: "message", listener: (value: any) => void): this
abstract member onMessageerror (listener: exn -> unit) : MessagePort
abstract member onMessageerror (listener: exn -> unit) : MessagePorton(event: "messageerror", listener: (error: Error) => void): this
abstract member once (event: string, listener: obj -> unit) : MessagePort
abstract member once (event: string, listener: obj -> unit) : MessagePortNode.js-specific extension to the EventTarget class that adds a once listener for the given event type. This is equivalent to calling on with the once option set to true.
abstract member onceClose (listener: Event -> unit) : MessagePort
abstract member onceClose (listener: Event -> unit) : MessagePortonce(event: "close", listener: (ev: Event) => void): this
abstract member onceMessage (listener: obj -> unit) : MessagePort
abstract member onceMessage (listener: obj -> unit) : MessagePortonce(event: "message", listener: (value: any) => void): this
abstract member onceMessageerror (listener: exn -> unit) : MessagePort
abstract member onceMessageerror (listener: exn -> unit) : MessagePortonce(event: "messageerror", listener: (error: Error) => void): this
abstract member postMessage (value: obj, ?transferList: Transferable array) : unit
abstract member postMessage (value: obj, ?transferList: Transferable array) : unitSends a JavaScript value to the receiving side of this channel. value is transferred in a way which is compatible with the HTML structured clone algorithm.
In particular, the significant differences to JSON are:
valuemay contain circular references.valuemay contain instances of builtin JS types such asRegExps,BigInts,Maps,Sets, etc.valuemay contain typed arrays, both usingArrayBuffers andSharedArrayBuffers.valuemay containWebAssembly.Moduleinstances.valuemay not contain native (C++-backed) objects other than:
import { MessageChannel } from 'node:worker_threads';
const { port1, port2 } = new MessageChannel();
port1.on('message', (message) => console.log(message));
const circularData = {};
circularData.foo = circularData;
// Prints: { foo: [Circular] }
port2.postMessage(circularData);
transferList may be a list of ArrayBuffer, MessagePort, and FileHandle objects. After transferring, they are not usable on the sending side of the channel anymore (even if they are not contained in value). Unlike with child processes, transferring handles such as network sockets is currently not supported.
If value contains SharedArrayBuffer instances, those are accessible from either thread. They cannot be listed in transferList.
value may still contain ArrayBuffer instances that are not in transferList; in that case, the underlying memory is copied rather than moved.
import { MessageChannel } from 'node:worker_threads';
const { port1, port2 } = new MessageChannel();
port1.on('message', (message) => console.log(message));
const uint8Array = new Uint8Array([ 1, 2, 3, 4 ]);
// This posts a copy of `uint8Array`:
port2.postMessage(uint8Array);
// This does not copy data, but renders `uint8Array` unusable:
port2.postMessage(uint8Array, [ uint8Array.buffer ]);
// The memory for the `sharedUint8Array` is accessible from both the
// original and the copy received by `.on('message')`:
const sharedUint8Array = new Uint8Array(new SharedArrayBuffer(4));
port2.postMessage(sharedUint8Array);
// This transfers a freshly created message port to the receiver.
// This can be used, for example, to create communication channels between
// multiple `Worker` threads that are children of the same parent thread.
const otherChannel = new MessageChannel();
port2.postMessage({ port: otherChannel.port1 }, [ otherChannel.port1 ]);
The message object is cloned immediately, and can be modified after posting without having side effects.
For more information on the serialization and deserialization mechanisms behind this API, see the serialization API of the node:v8 module.
@since v10.5.0
abstract member ref () : unit
abstract member ref () : unitOpposite of unref(). Calling ref() on a previously unref()ed port does not let the program exit if it's the only active handle left (the default behavior). If the port is ref()ed, calling ref() again has no effect.
If listeners are attached or removed using .on('message'), the port is ref()ed and unref()ed automatically depending on whether listeners for the event exist.
@since v10.5.0
abstract member removeAllListeners (?type: string) : MessagePort
abstract member removeAllListeners (?type: string) : MessagePortNode.js-specific extension to the EventTarget class. If type is specified, removes all registered listeners for type, otherwise removes all registered listeners.
@since v14.5.0
abstract member removeListener (event: string, listener: obj -> unit, ?options: EventListenerOptions) : MessagePort
abstract member removeListener (event: string, listener: obj -> unit, ?options: EventListenerOptions) : MessagePortNode.js-specific extension to the EventTarget class that removes the listener for the given type. The only difference between removeListener() and removeEventListener() is that removeListener() will return a reference to the EventTarget.
abstract member removeListenerClose (listener: Event -> unit, ?options: EventListenerOptions) : MessagePort
abstract member removeListenerClose (listener: Event -> unit, ?options: EventListenerOptions) : MessagePortremoveListener(event: "close", listener: (ev: Event) => void, options?: EventListenerOptions): this
abstract member removeListenerMessage (listener: obj -> unit, ?options: EventListenerOptions) : MessagePort
abstract member removeListenerMessage (listener: obj -> unit, ?options: EventListenerOptions) : MessagePortremoveListener(event: "message", listener: (value: any) => void, options?: EventListenerOptions): this
abstract member removeListenerMessageerror (listener: exn -> unit, ?options: EventListenerOptions) : MessagePort
abstract member removeListenerMessageerror (listener: exn -> unit, ?options: EventListenerOptions) : MessagePortremoveListener(event: "messageerror", listener: (error: Error) => void, options?: EventListenerOptions): this
abstract member start () : unit
abstract member start () : unitStarts receiving messages on this MessagePort. When using this port as an event emitter, this is called automatically once 'message' listeners are attached.
This method exists for parity with the Web MessagePort API. In Node.js, it is only useful for ignoring messages when no event listener is present. Node.js also diverges in its handling of .onmessage. Setting it automatically calls .start(), but unsetting it lets messages queue up until a new handler is set or the port is discarded.
@since v10.5.0
abstract member unref () : unit
abstract member unref () : unitCalling unref() on a port allows the thread to exit if this is the only active handle in the event system. If the port is already unref()ed calling unref() again has no effect.
If listeners are attached or removed using .on('message'), the port is ref()ed and unref()ed automatically depending on whether listeners for the event exist.
@since v10.5.0