Class Transport

Whether this transport is still holdable, or has been handed on.

Establishes the link. Rejects when it cannot be established, or when the transport was handed on.

Waits for the next message on a subscribed topic, or null once the link has ended. Rejects when the link fails, or when the transport was handed on.

Publishes a payload to a topic: bytes, or text such as a reading written out. Rejects when the link refuses it, or when the transport was handed on.

Subscribes to a topic, with the + and # wildcards. Rejects when the link refuses it, or when the transport was handed on.

Creates a CoAP transport from endpoint settings.

Wraps a transport in a link that loses packets and goes down.

The wrapped transport is consumed. Every fault is off unless the options name it, so a link that only drops packets says only that.

Wraps a transport so its next failures sends fail.

This is how a caller checks that a ladder falls through to its next rung, or that a buffer fills, without unplugging anything. The wrapped transport is consumed.

Wraps a link written in JavaScript as a transport.

handlers needs connect(), send(topic, payload), and subscribe(topic), each returning a promise or nothing. A recv() that resolves to a message, { topic, payload } with the payload as a buffer or text, or to null once the link has ended, makes it a link that delivers: it is called again as soon as it settles, from the moment the transport connects. A recv that throws ends the link until the next connect, and the next receive rejects with what it threw. Without recv the transport only sends, and a ladder never listens on it. The methods are called on handlers, so a class instance works as it is.

Creates an MQTT transport from broker settings.