Skip to content

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
AssemblyXantham.Fable.Node
ImplementsNodeEventTarget

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

Node.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
addListener(event: "close", listener: (ev: Event) => void): this
abstract member addListenerMessage (listener: obj -> unit) : MessagePort
addListener(event: "message", listener: (value: any) => void): this
abstract member addListenerMessageerror (listener: exn -> unit) : MessagePort
addListener(event: "messageerror", listener: (error: Error) => void): this
abstract member close () : unit

Disables 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

Node.js-specific extension to the EventTarget class that dispatches the arg to the list of handlers for type.

abstract member emitClose (ev: Event) : bool
emit(event: "close", ev: Event): boolean
abstract member emitMessage (value: obj) : bool
emit(event: "message", value: any): boolean
abstract member emitMessageerror (error: exn) : bool
emit(event: "messageerror", error: Error): boolean
abstract member hasRef () : bool

If 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

Node.js-specific alias for eventTarget.removeEventListener().

abstract member offClose (listener: Event -> unit, ?options: EventListenerOptions) : MessagePort
off(event: "close", listener: (ev: Event) => void, options?: EventListenerOptions): this
abstract member offMessage (listener: obj -> unit, ?options: EventListenerOptions) : MessagePort
off(event: "message", listener: (value: any) => void, options?: EventListenerOptions): this
abstract member offMessageerror (listener: exn -> unit, ?options: EventListenerOptions) : MessagePort
off(event: "messageerror", listener: (error: Error) => void, options?: EventListenerOptions): this
abstract member on (event: string, listener: obj -> unit) : MessagePort

Node.js-specific alias for eventTarget.addEventListener().

abstract member onClose (listener: Event -> unit) : MessagePort
on(event: "close", listener: (ev: Event) => void): this
abstract member onMessage (listener: obj -> unit) : MessagePort
on(event: "message", listener: (value: any) => void): this
abstract member onMessageerror (listener: exn -> unit) : MessagePort
on(event: "messageerror", listener: (error: Error) => void): this
abstract member once (event: string, listener: obj -> unit) : MessagePort

Node.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
once(event: "close", listener: (ev: Event) => void): this
abstract member onceMessage (listener: obj -> unit) : MessagePort
once(event: "message", listener: (value: any) => void): this
abstract member onceMessageerror (listener: exn -> unit) : MessagePort
once(event: "messageerror", listener: (error: Error) => void): this
abstract member postMessage (value: obj, ?transferList: Transferable array) : unit

Sends 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:

  • value may contain circular references.
  • value may contain instances of builtin JS types such as RegExps, BigInts, Maps, Sets, etc.
  • value may contain typed arrays, both using ArrayBuffers and SharedArrayBuffers.
  • value may contain WebAssembly.Module instances.
  • value may 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

Opposite 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

Node.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

Node.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
removeListener(event: "close", listener: (ev: Event) => void, options?: EventListenerOptions): this
abstract member removeListenerMessage (listener: obj -> unit, ?options: EventListenerOptions) : MessagePort
removeListener(event: "message", listener: (value: any) => void, options?: EventListenerOptions): this
abstract member removeListenerMessageerror (listener: exn -> unit, ?options: EventListenerOptions) : MessagePort
removeListener(event: "messageerror", listener: (error: Error) => void, options?: EventListenerOptions): this
abstract member start () : unit

Starts 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

Calling 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